[jira] [Created] (FLINK-4304) Jar names that contain whitespace cause problems in web client

2016-08-02 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4304: --- Summary: Jar names that contain whitespace cause problems in web client Key: FLINK-4304 URL: https://issues.apache.org/jira/browse/FLINK-4304 Project: Flink

[GitHub] flink pull request #2325: [cleanup] remove unused code

2016-08-02 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2325 [cleanup] remove unused code Removes some unused code an tests the GitHub integration with Jenkins :) - remove unused utility testing function - remove leftover FLINK_CONF_DIR jvm property

[GitHub] flink issue #2326: [FLINK-4305] test Jenkins GitHub integration

2016-08-02 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2326 Cool, thanks for setting this up. Empty commit just for reference/triggering? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-4305) Build pull requests with Jenkins

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403725#comment-15403725 ] ASF GitHub Bot commented on FLINK-4305: --- Github user StephanEwen commented on the issue:

[jira] [Closed] (FLINK-4292) HCatalog project incorrectly set up

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4292. --- > HCatalog project incorrectly set up > --- > > Key:

[jira] [Resolved] (FLINK-4292) HCatalog project incorrectly set up

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4292. - Resolution: Fixed Fixed for - 1.1.1 via 70a0479c0a1469c6c69c3c1112946f7ae32632ca - 1.2.0 via

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403822#comment-15403822 ] ASF GitHub Bot commented on FLINK-4084: --- Github user alkagin commented on the issue:

[GitHub] flink issue #2149: [FLINK-4084] Add configDir parameter to CliFrontend and f...

2016-08-02 Thread alkagin
Github user alkagin commented on the issue: https://github.com/apache/flink/pull/2149 I am on vacations, I will address your comments as soon as I get back. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-02 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403843#comment-15403843 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- Ok. bq.If we use pooling, I think we should

[jira] [Commented] (FLINK-4304) Jar names that contain whitespace cause problems in web client

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403916#comment-15403916 ] ASF GitHub Bot commented on FLINK-4304: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #2325: [cleanup] remove unused code

2016-08-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2325 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4290. - Resolution: Fixed Fix Version/s: 1.1.1 1.2.0 Fixed for - 1.1.1 in

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403775#comment-15403775 ] Stephan Ewen commented on FLINK-4094: - If we use pooling, I think we should just follow the exact same

[GitHub] flink pull request #2326: [FLINK-4305] test Jenkins GitHub integration

2016-08-02 Thread mxm
Github user mxm closed the pull request at: https://github.com/apache/flink/pull/2326 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4305) Build pull requests with Jenkins

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403817#comment-15403817 ] ASF GitHub Bot commented on FLINK-4305: --- Github user mxm closed the pull request at:

[jira] [Commented] (FLINK-4305) Build pull requests with Jenkins

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403816#comment-15403816 ] ASF GitHub Bot commented on FLINK-4305: --- Github user mxm commented on the issue:

[jira] [Updated] (FLINK-4304) Jar names that contain whitespace cause problems in web client

2016-08-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4304: Affects Version/s: 1.1.0 > Jar names that contain whitespace cause problems in web client >

[GitHub] flink issue #2324: Bump version to 1.2-SNAPSHOT

2016-08-02 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2324 About time to bump the version ;-) I think the variables in the docs also need adjustments. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Comment Edited] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

2016-08-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403771#comment-15403771 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4280 at 8/2/16 10:59 AM: -

[jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

2016-08-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403771#comment-15403771 ] Tzu-Li (Gordon) Tai commented on FLINK-4280: [~StephanEwen] - *Can we keep the Kafka08 and

[jira] [Comment Edited] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

2016-08-02 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403771#comment-15403771 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4280 at 8/2/16 10:58 AM: -

[GitHub] flink issue #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1)

2016-08-02 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2315 Awesome, thanks for that great contribution. Give us a bit of time to look at it. Its a big chunk of code! One thing I thought while glancing over this: We may want to do is to split

[jira] [Resolved] (FLINK-4285) Non-existing example in Flink quickstart setup documentation

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4285. - Resolution: Fixed Fix Version/s: (was: 1.1.0) 1.1.1

[jira] [Closed] (FLINK-4285) Non-existing example in Flink quickstart setup documentation

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4285. --- > Non-existing example in Flink quickstart setup documentation >

[jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition

2016-08-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403722#comment-15403722 ] Till Rohrmann commented on FLINK-3414: -- Hi [~ivan.mushketyk], I think it would be a good idea to

[jira] [Resolved] (FLINK-4298) Clean up Storm Compatibility Dependencies

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4298. - Fixed via 0ea2596e1b605c1eedb843273660ef1366463313

[jira] [Closed] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4290. --- > CassandraConnectorTest deadlocks > > > Key: FLINK-4290

[jira] [Created] (FLINK-4306) Fix Flink and Storm dependencies in flink-storm and flink-storm-examples

2016-08-02 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4306: --- Summary: Fix Flink and Storm dependencies in flink-storm and flink-storm-examples Key: FLINK-4306 URL: https://issues.apache.org/jira/browse/FLINK-4306 Project: Flink

[jira] [Created] (FLINK-4305) Build pull requests with Jenkins

2016-08-02 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4305: - Summary: Build pull requests with Jenkins Key: FLINK-4305 URL: https://issues.apache.org/jira/browse/FLINK-4305 Project: Flink Issue Type: Task

[jira] [Resolved] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4251. - Resolution: Fixed Fix Version/s: 1.1.1 1.2.0 Fixed for - 1.1.1 via

[jira] [Closed] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4251. --- > Add possiblity for the RMQ Streaming Sink to customize the queue >

[jira] [Closed] (FLINK-4298) Clean up Storm Compatibility Dependencies

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4298. --- > Clean up Storm Compatibility Dependencies > - > >

[jira] [Commented] (FLINK-4275) Generic Folding, Reducing and List states behave differently from other state backends

2016-08-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403807#comment-15403807 ] Ufuk Celebi commented on FLINK-4275: I just noticed that the behaviour has changed, too. I know that

[jira] [Updated] (FLINK-4300) Improve error message for different Scala versions of JM and Client

2016-08-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4300: Affects Version/s: 1.1.0 > Improve error message for different Scala versions of JM and Client >

[jira] [Updated] (FLINK-4303) Add CEP examples

2016-08-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4303: Affects Version/s: 1.1.0 > Add CEP examples > > > Key: FLINK-4303

[jira] [Commented] (FLINK-4305) Build pull requests with Jenkins

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403693#comment-15403693 ] ASF GitHub Bot commented on FLINK-4305: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request #2326: [FLINK-4305] test Jenkins GitHub integration

2016-08-02 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2326 [FLINK-4305] test Jenkins GitHub integration You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink jenkins-github Alternatively you can review

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403714#comment-15403714 ] ASF GitHub Bot commented on FLINK-1984: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-2090) toString of CollectionInputFormat takes long time when the collection is huge

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403709#comment-15403709 ] ASF GitHub Bot commented on FLINK-2090: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2326: [FLINK-4305] test Jenkins GitHub integration

2016-08-02 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2326 Sure, no problem. The empty commit is just for testing the integration. Can't break anything with an empty commit :) --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-4305) Build pull requests with Jenkins

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403753#comment-15403753 ] ASF GitHub Bot commented on FLINK-4305: --- Github user mxm commented on the issue:

[jira] [Closed] (FLINK-4305) Build pull requests with Jenkins

2016-08-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4305. - Resolution: Fixed Pull requests are now built with Jenkins:

[GitHub] flink issue #2323: [FLINK-2090] toString of CollectionInputFormat takes long...

2016-08-02 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2323 Looks good. Can you remove the Guava dependency, though? We try to avoid Guava as much as possible, because it causes too many dependency issues... --- If your project is set up for it, you can

[jira] [Assigned] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-4290: --- Assignee: Stephan Ewen > CassandraConnectorTest deadlocks >

[GitHub] flink issue #2326: [FLINK-4305] test Jenkins GitHub integration

2016-08-02 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2326 Looks like the integration works. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[GitHub] flink pull request #2327: [FLINK-4304] [runtime-web] Jar names that contain ...

2016-08-02 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2327 [FLINK-4304] [runtime-web] Jar names that contain whitespace cause problems in web client Thanks for contributing to Apache Flink. Before you open your pull request, please take the following

[GitHub] flink issue #2274: [FLINK-4180] [FLINK-4181] [table] add Batch SQL and Strea...

2016-08-02 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2274 Thanks @wuchong. I will add some additional comments/formatting and merge it... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request #2109: [FLINK-3677] FileInputFormat: Allow to specify inc...

2016-08-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2109#discussion_r73162978 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/io/FileInputFormatTest.java --- @@ -257,41 +257,22 @@ public void testFileInputSplit() {

[jira] [Commented] (FLINK-4203) Improve Table API documentation

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404096#comment-15404096 ] ASF GitHub Bot commented on FLINK-4203: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404097#comment-15404097 ] ASF GitHub Bot commented on FLINK-3677: --- Github user mxm commented on the issue:

[GitHub] flink pull request #2282: [FLINK-3940] [table] Add support for ORDER BY OFFS...

2016-08-02 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2282#discussion_r73172521 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala --- @@ -150,6 +150,47 @@ case class Sort(order:

[GitHub] flink issue #2305: [FLINK-4271] [DataStreamAPI] Enable CoGroupedStreams and ...

2016-08-02 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2305 @wuchong The CI fails because this change breaks backwards compatibility. I understand though that this is a pretty critical change and may actually warrant to break the backwards compatibility.

[GitHub] flink pull request #2282: [FLINK-3940] [table] Add support for ORDER BY OFFS...

2016-08-02 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2282#discussion_r73172351 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala --- @@ -150,6 +150,47 @@ case class Sort(order:

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73159333 --- Diff: docs/internals/flink_security.md --- @@ -0,0 +1,87 @@ +--- +title: "Flink Security" +# Top navigation +top-nav-group: internals

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404003#comment-15404003 ] ASF GitHub Bot commented on FLINK-3929: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73160331 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetentionTestBase.java ---

[GitHub] flink pull request #2274: [FLINK-4180] [FLINK-4181] [table] add Batch SQL an...

2016-08-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2274 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink issue #2314: [FLINK-3298] Implement ActiveMQ streaming connector

2016-08-02 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2314 Hi @mushketyk Thanks for opening this big contribution. I would like to take a short step back, though. For new modules and new integrations, we need to have consensus first

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404008#comment-15404008 ] ASF GitHub Bot commented on FLINK-3929: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73159602 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/RollingSinkSecuredITCase.java --- @@ -0,0

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404047#comment-15404047 ] ASF GitHub Bot commented on FLINK-3677: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2109: [FLINK-3677] FileInputFormat: Allow to specify inc...

2016-08-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2109#discussion_r73162004 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java --- @@ -274,7 +272,7 @@

[jira] [Commented] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404149#comment-15404149 ] ASF GitHub Bot commented on FLINK-4271: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403958#comment-15403958 ] Stephan Ewen commented on FLINK-3298: - I would like to start a discussion about whether we should add

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73159038 --- Diff: flink-core/src/main/java/org/apache/flink/util/Preconditions.java --- @@ -293,6 +293,16 @@ private static String format(@Nullable String template,

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403999#comment-15403999 ] ASF GitHub Bot commented on FLINK-3929: --- Github user mxm commented on a diff in the pull request:

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404000#comment-15404000 ] ASF GitHub Bot commented on FLINK-3929: --- Github user mxm commented on a diff in the pull request:

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404060#comment-15404060 ] ASF GitHub Bot commented on FLINK-3677: --- Github user mxm commented on a diff in the pull request:

[jira] [Resolved] (FLINK-4180) Create a batch SQL example

2016-08-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4180. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 123c637e804bfdd6569051cf705ec73b5cb95352.

[GitHub] flink pull request #2293: [FLINK-4203] [table] [docs] Improve Table API docu...

2016-08-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2293 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4203) Improve Table API documentation

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404108#comment-15404108 ] ASF GitHub Bot commented on FLINK-4203: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-4081) FieldParsers should support empty strings

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404107#comment-15404107 ] ASF GitHub Bot commented on FLINK-4081: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404005#comment-15404005 ] ASF GitHub Bot commented on FLINK-3929: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73159441 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java --- @@ -0,0 +1,218 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404050#comment-15404050 ] ASF GitHub Bot commented on FLINK-3677: --- Github user mxm commented on a diff in the pull request:

[jira] [Resolved] (FLINK-4181) Add a basic streaming Table API example

2016-08-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4181. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 123c637e804bfdd6569051cf705ec73b5cb95352.

[GitHub] flink issue #2298: [FLINK-4247] [table] CsvTableSource.getDataSet() expects ...

2016-08-02 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2298 Would be great to reflect the "do not use" with proper visibility. A JavaDoc comment is usually not helping at all. Also, the dependency on the java API classes in the Scala classes does

[jira] [Commented] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404102#comment-15404102 ] ASF GitHub Bot commented on FLINK-4247: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404120#comment-15404120 ] Maximilian Michels commented on FLINK-4094: --- Yes, it was undocumented. Initially, I thought

[jira] [Commented] (FLINK-3940) Add support for ORDER BY OFFSET FETCH

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404133#comment-15404133 ] ASF GitHub Bot commented on FLINK-3940: --- Github user twalthr commented on a diff in the pull

[jira] [Resolved] (FLINK-4246) Allow Specifying Multiple Metrics Reporters

2016-08-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-4246. - Resolution: Fixed This was merged a while back > Allow Specifying Multiple Metrics

[jira] [Commented] (FLINK-4180) Create a batch SQL example

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403930#comment-15403930 ] ASF GitHub Bot commented on FLINK-4180: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition

2016-08-02 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403931#comment-15403931 ] Ivan Mushketyk commented on FLINK-3414: --- Thank you [~till.rohrmann], I think you are right. I'll

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403961#comment-15403961 ] Maximilian Michels commented on FLINK-4094: --- Thanks [~StephanEwen] for clyariying that we can't

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-08-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2275#discussion_r73158919 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/JaasConfiguration.java --- @@ -0,0 +1,158 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-08-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404033#comment-15404033 ] Stephan Ewen commented on FLINK-3298: - Another option we have been discussing a lot, is to have a

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404048#comment-15404048 ] ASF GitHub Bot commented on FLINK-3677: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2109: [FLINK-3677] FileInputFormat: Allow to specify inc...

2016-08-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2109#discussion_r73162125 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java --- @@ -274,7 +272,7 @@

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404049#comment-15404049 ] ASF GitHub Bot commented on FLINK-3677: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request #2109: [FLINK-3677] FileInputFormat: Allow to specify inc...

2016-08-02 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2109#discussion_r73162167 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/io/GlobFilePathFilterTest.java --- @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache

[GitHub] flink issue #2109: [FLINK-3677] FileInputFormat: Allow to specify include/ex...

2016-08-02 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2109 Just had a brief look. Looks nice. Actually, I like how you moved the file filter to the `FileInputFormat` instead of having it as a special case of the file monitoring source. I think you

[jira] [Commented] (FLINK-3940) Add support for ORDER BY OFFSET FETCH

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404137#comment-15404137 ] ASF GitHub Bot commented on FLINK-3940: --- Github user twalthr commented on a diff in the pull

[GitHub] flink pull request #2282: [FLINK-3940] [table] Add support for ORDER BY OFFS...

2016-08-02 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2282#discussion_r73171110 --- Diff: docs/apis/table.md --- @@ -606,6 +606,28 @@ Table result = in.orderBy("a.asc"); + + Offset +

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403938#comment-15403938 ] ASF GitHub Bot commented on FLINK-3929: --- Github user mxm commented on the issue:

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-02 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2275 > Yes, it is not essential to run the secure test case all the time as it consumes more cycles. Do you have any suggestion on controlling this through some mvn/surefire plugin configuration? I

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404010#comment-15404010 ] ASF GitHub Bot commented on FLINK-3929: --- Github user mxm commented on a diff in the pull request:

[jira] [Resolved] (FLINK-4203) Improve Table API documentation

2016-08-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4203. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 3f1e8b91574d66a8e9d8b74a6be1227535064405.

[jira] [Commented] (FLINK-3940) Add support for ORDER BY OFFSET FETCH

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404141#comment-15404141 ] ASF GitHub Bot commented on FLINK-3940: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-4224) Exception after successful execution os job submitted through the web interface.

2016-08-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404157#comment-15404157 ] Aljoscha Krettek commented on FLINK-4224: - [~kkl0u] is this still an issue on the new 1.1 RC? >

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403926#comment-15403926 ] ASF GitHub Bot commented on FLINK-3298: --- Github user StephanEwen commented on the issue:

  1   2   >