[GitHub] flink issue #2374: [FLINK-3950] Add Meter Metric Type

2016-08-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2374 will merge this today. --- 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,

[jira] [Commented] (FLINK-3950) Add Meter Metric Type

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445100#comment-15445100 ] ASF GitHub Bot commented on FLINK-3950: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4519) scala maxLineLength increased to 120

2016-08-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445103#comment-15445103 ] Chesnay Schepler commented on FLINK-4519: - Could you provide a reason as to why th

[GitHub] flink issue #2418: [FLINK-4245] JMXReporter exposes all defined variables

2016-08-29 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2418 The wrapper is a nice idea, will look into 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 your project does not have this featur

[jira] [Commented] (FLINK-4245) Metric naming improvements

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445149#comment-15445149 ] ASF GitHub Bot commented on FLINK-4245: --- Github user zentol commented on the issue:

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-08-29 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r76567175 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/FieldAccessorTest.java --- @@ -0,0 +1,280 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-08-29 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r76567285 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/FieldAccessorTest.java --- @@ -0,0 +1,336 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[jira] [Commented] (FLINK-4519) scala maxLineLength increased to 120

2016-08-29 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445211#comment-15445211 ] shijinkui commented on FLINK-4519: -- Scala function's parameter is longger, and less than

[jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

2016-08-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445237#comment-15445237 ] Maximilian Michels commented on FLINK-2608: --- Thanks for letting us know! > Arra

[GitHub] flink issue #2094: [FLINK-3702] Make FieldAccessors support nested field exp...

2016-08-29 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2094 Thanks for updating the PR @ggevay. Beside some small comments the PR looks good to merge. I can fix them when merging. @rmetzger you opened the Jira issue. Do you also want to take a final look

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[GitHub] flink issue #2426: [FLINK-3677] Remove Guava dependency from flink-core

2016-08-29 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2426 Thanks for removing Guava from the test scope as requested by the community. Merging this. --- 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-3677) FileInputFormat: Allow to specify include/exclude file name patterns

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

[GitHub] flink issue #2426: [FLINK-3677] Remove Guava dependency from flink-core

2016-08-29 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2426 Merged with 7a539c05a4a7239801f4fa9bc7313e6f30ff85f5. Could you close the PR, forgot to include the auto-close message to your commit :) --- If your project is set up for it, you can reply to this email

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

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

[GitHub] flink pull request #2426: [FLINK-3677] Remove Guava dependency from flink-co...

2016-08-29 Thread mushketyk
Github user mushketyk closed the pull request at: https://github.com/apache/flink/pull/2426 --- 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 e

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

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445283#comment-15445283 ] ASF GitHub Bot commented on FLINK-3677: --- Github user mushketyk closed the pull reque

[GitHub] flink issue #2426: [FLINK-3677] Remove Guava dependency from flink-core

2016-08-29 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2426 Already merged. Closing. --- 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 wishe

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

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445282#comment-15445282 ] ASF GitHub Bot commented on FLINK-3677: --- Github user mushketyk commented on the issu

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

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445281#comment-15445281 ] ASF GitHub Bot commented on FLINK-3677: --- Github user mushketyk commented on the issu

[GitHub] flink issue #2426: [FLINK-3677] Remove Guava dependency from flink-core

2016-08-29 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2426 @mxm Sure :) --- 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

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-08-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445296#comment-15445296 ] Stephan Ewen commented on FLINK-4485: - Thanks for opening this and analyzing it so tho

[jira] [Created] (FLINK-4524) JobManagerProcessReapingTest.testReapProcessOnFailure unstable

2016-08-29 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4524: - Summary: JobManagerProcessReapingTest.testReapProcessOnFailure unstable Key: FLINK-4524 URL: https://issues.apache.org/jira/browse/FLINK-4524 Project: Flink

[jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable

2016-08-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445309#comment-15445309 ] Robert Metzger commented on FLINK-3704: --- Another failure: https://s3.amazonaws.com/

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

2016-08-29 Thread chobeat
Github user chobeat commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76575651 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala --- @@ -0,0 +1,286 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445312#comment-15445312 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chobeat commented on a diff in

[GitHub] flink issue #2429: [FLINK-4519] scala maxLineLength increased to 120

2016-08-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2429 Things like this need to be discussed before we can make such a change. It was a conscious decision initially to have 100 characters line length. I personally do not mind 120 char line

[jira] [Commented] (FLINK-4519) scala maxLineLength increased to 120

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445327#comment-15445327 ] ASF GitHub Bot commented on FLINK-4519: --- Github user StephanEwen commented on the is

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-08-29 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r76576754 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/FieldAccessorTest.java --- @@ -0,0 +1,280 @@ +/* + * Licensed to the Apache Sof

[GitHub] flink pull request #2094: [FLINK-3702] Make FieldAccessors support nested fi...

2016-08-29 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/2094#discussion_r76576801 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/FieldAccessorTest.java --- @@ -0,0 +1,336 @@ +/* + * Licensed to the Apache Sof

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445334#comment-15445334 ] ASF GitHub Bot commented on FLINK-3702: --- Github user ggevay commented on a diff in t

[GitHub] flink issue #2428: [FLINK-4517] scala code refactoring

2016-08-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2428 I am a bit cautious with such changes. There is no necessity to change the code, it only looses history, and there is always a slight risk of a new bug appearing. Some of the styles you

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445332#comment-15445332 ] ASF GitHub Bot commented on FLINK-3702: --- Github user ggevay commented on a diff in t

[jira] [Commented] (FLINK-4517) scala code refactoring

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445335#comment-15445335 ] ASF GitHub Bot commented on FLINK-4517: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-08-29 Thread Niels Basjes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445374#comment-15445374 ] Niels Basjes commented on FLINK-4485: - No, I had a quick look at the code and I could

[jira] [Commented] (FLINK-4489) Implement TaskManager's SlotManager

2016-08-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445372#comment-15445372 ] Till Rohrmann commented on FLINK-4489: -- No this refers to the {{TaskManager's}} {{Slo

[jira] [Commented] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445388#comment-15445388 ] ASF GitHub Bot commented on FLINK-4439: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-08-29 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445385#comment-15445385 ] Maximilian Michels commented on FLINK-4485: --- Thanks for reportig [~nielsbasjes].

[GitHub] flink pull request #2414: [FLINK-4341] Let idle consumer subtasks emit max v...

2016-08-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2414 --- 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 enab

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445393#comment-15445393 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445391#comment-15445391 ] ASF GitHub Bot commented on FLINK-4311: --- Github user nielsbasjes commented on the is

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

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

[GitHub] flink issue #2330: FLINK-4311 Fixed several problems in TableInputFormat

2016-08-29 Thread nielsbasjes
Github user nielsbasjes commented on the issue: https://github.com/apache/flink/pull/2330 Current version has a problem in building the shaded jars. I runs into an infinite loop in creating the dependency-reduced-pom.xml as described here: **Shade Plugin gets stuck in inf

[GitHub] flink issue #2414: [FLINK-4341] Let idle consumer subtasks emit max value wa...

2016-08-29 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2414 Thank you for the pull request. I'll merge it to master and the release-1.1 branch. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[GitHub] flink issue #2397: [FLINK-4439] Validate 'bootstrap.servers' config in flink...

2016-08-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2397 @gheo21 Do you plan to update this Pull Request? --- 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

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

2016-08-29 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76580310 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala --- @@ -0,0 +1,286 @@ +/* + * Licensed to

[GitHub] flink issue #2388: [FLINK-4347][cluster management] Implement SlotManager co...

2016-08-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2388 Just to avoid doubt: This should run as part of the ResourceManager, correct? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If y

[jira] [Resolved] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

2016-08-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4341. --- Resolution: Fixed Assignee: Tzu-Li (Gordon) Tai (was: Robert Metzger) Resolved for mast

[jira] [Commented] (FLINK-4486) JobManager not fully running when yarn-session.sh finishes

2016-08-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445414#comment-15445414 ] Till Rohrmann commented on FLINK-4486: -- I think that's the right way to fix the probl

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445398#comment-15445398 ] ASF GitHub Bot commented on FLINK-4341: --- Github user rmetzger commented on the issue

[GitHub] flink issue #2397: [FLINK-4439] Validate 'bootstrap.servers' config in flink...

2016-08-29 Thread gheo21
Github user gheo21 commented on the issue: https://github.com/apache/flink/pull/2397 Hi @StephanEwen, Thanks for taking a look at this. This would only make sense if I catch the exception in the catch block of the getPartitionsForTopic method. However, I can only check t

[jira] [Commented] (FLINK-4347) Implement SlotManager core

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445383#comment-15445383 ] ASF GitHub Bot commented on FLINK-4347: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445427#comment-15445427 ] ASF GitHub Bot commented on FLINK-4439: --- Github user gheo21 commented on the issue:

[jira] [Created] (FLINK-4525) Drop the "eager split pre-assignment" code paths

2016-08-29 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4525: --- Summary: Drop the "eager split pre-assignment" code paths Key: FLINK-4525 URL: https://issues.apache.org/jira/browse/FLINK-4525 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-4419) Batch improvement for supporting dfs as a ResultPartitionType

2016-08-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445435#comment-15445435 ] Till Rohrmann commented on FLINK-4419: -- At the moment, the blocking results are kept

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445449#comment-15445449 ] ASF GitHub Bot commented on FLINK-4341: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-4514) ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445459#comment-15445459 ] ASF GitHub Bot commented on FLINK-4514: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-4514) ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream

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

[GitHub] flink issue #2414: [FLINK-4341] Let idle consumer subtasks emit max value wa...

2016-08-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2414 Thanks @rmetzger ! --- 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, o

[jira] [Commented] (FLINK-4525) Drop the "eager split pre-assignment" code paths

2016-08-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445443#comment-15445443 ] Fabian Hueske commented on FLINK-4525: -- +1 to drop it. This feature is well hidden (o

[GitHub] flink pull request #2432: [FLINK-4514][kinesis-connector] Handle unexpected ...

2016-08-29 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/2432 [FLINK-4514][kinesis-connector] Handle unexpected ExpiredIteratorExceptions Handle any unexpected {{ExpiredIteratorException}}s on {{getRecords()}} calls be refreshing the failing shard iterator wi

[jira] [Assigned] (FLINK-4478) Implement heartbeat logic

2016-08-29 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4478: Assignee: Till Rohrmann > Implement heartbeat logic > - > >

[GitHub] flink issue #2432: [FLINK-4514][kinesis-connector] Handle unexpected Expired...

2016-08-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2432 @rmetzger I know it might be a bit of a rush, but could you have a quick look at this too? It's not a critical blocker, but might as well would be good to make it into the 1.1.2 patch freeze.

[GitHub] flink pull request #2433: docs: fixed timestamp extractor documentation Java...

2016-08-29 Thread jpzk
GitHub user jpzk opened a pull request: https://github.com/apache/flink/pull/2433 docs: fixed timestamp extractor documentation Java example You can merge this pull request into a Git repository by running: $ git pull https://github.com/jpzk/flink master Alternatively you can

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-08-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445493#comment-15445493 ] Robert Metzger commented on FLINK-4485: --- I looked a bit into the issue because I'm w

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

2016-08-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445495#comment-15445495 ] Robert Metzger commented on FLINK-4485: --- Sorry, I didn't refresh before writing a co

[jira] [Resolved] (FLINK-4287) Unable to access secured HBase from a yarn-session.

2016-08-29 Thread Niels Basjes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Niels Basjes resolved FLINK-4287. - Resolution: Fixed The change has been committed > Unable to access secured HBase from a yarn-sess

[GitHub] flink issue #2428: [FLINK-4517] scala code refactoring

2016-08-29 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/2428 @StephanEwen Thank for your reply. These code change such as case class usage are not forced to observe. But there are scala best practice. We can update every kind of problem, at same time upd

[jira] [Commented] (FLINK-4517) scala code refactoring

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445550#comment-15445550 ] ASF GitHub Bot commented on FLINK-4517: --- Github user shijinkui commented on the issu

[jira] [Commented] (FLINK-4519) scala maxLineLength increased to 120

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445552#comment-15445552 ] ASF GitHub Bot commented on FLINK-4519: --- Github user shijinkui commented on the issu

[GitHub] flink issue #2429: [FLINK-4519] scala maxLineLength increased to 120

2016-08-29 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/2429 @StephanEwen Thanks for your reply. That's OK. We can discuss first --- 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 proje

[jira] [Commented] (FLINK-4519) scala maxLineLength increased to 120

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445553#comment-15445553 ] ASF GitHub Bot commented on FLINK-4519: --- Github user shijinkui closed the pull reque

[GitHub] flink pull request #2429: [FLINK-4519] scala maxLineLength increased to 120

2016-08-29 Thread shijinkui
Github user shijinkui closed the pull request at: https://github.com/apache/flink/pull/2429 --- 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 e

[GitHub] flink pull request #2376: [FLINK-3755] Introduce key groups for key-value st...

2016-08-29 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/2376 --- 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

[jira] [Commented] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445565#comment-15445565 ] ASF GitHub Bot commented on FLINK-3755: --- Github user StefanRRichter closed the pull

[GitHub] flink issue #2388: [FLINK-4347][cluster management] Implement SlotManager co...

2016-08-29 Thread KurtYoung
Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/2388 Yes, this is for ResourceManager --- 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 a

[jira] [Commented] (FLINK-4347) Implement SlotManager core

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445597#comment-15445597 ] ASF GitHub Bot commented on FLINK-4347: --- Github user KurtYoung commented on the issu

[GitHub] flink issue #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to let typ...

2016-08-29 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2337 @StephanEwen I have added `TypeInfoFactory` support to the Scala API and added tests for it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation

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

[jira] [Commented] (FLINK-4522) Gelly link broken in homepage

2016-08-29 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445646#comment-15445646 ] Greg Hogan commented on FLINK-4522: --- Should we add another redirect or simply replace th

[jira] [Commented] (FLINK-4522) Gelly link broken in homepage

2016-08-29 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445732#comment-15445732 ] Vasia Kalavri commented on FLINK-4522: -- Hi Greg, what is the current redirect? The ge

[jira] [Commented] (FLINK-4522) Gelly link broken in homepage

2016-08-29 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445744#comment-15445744 ] Greg Hogan commented on FLINK-4522: --- >From /apis/batch/libs/gelly/index.html to /dev/lib

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-08-29 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445747#comment-15445747 ] Timo Walther commented on FLINK-4469: - Instead of using an `Iterable` as return type,

[GitHub] flink pull request #:

2016-08-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/commit/7b574cf5b6e7549ae53ea0846022c4430a979a01#commitcomment-18811350 Does it make sense to mention that one can set the parallelism of the source independently to the number of Kinesis shards?

[GitHub] flink pull request #:

2016-08-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/commit/7a539c05a4a7239801f4fa9bc7313e6f30ff85f5#commitcomment-18811359 In flink-core/src/test/java/org/apache/flink/api/common/io/FileInputFormatTest.java: In flink-core/src/test/java/org/apach

[jira] [Commented] (FLINK-4525) Drop the "eager split pre-assignment" code paths

2016-08-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445758#comment-15445758 ] Stephan Ewen commented on FLINK-4525: - Thanks! > Drop the "eager split pre-assignment

[GitHub] flink issue #2422: FLINK-4499: [WIP] Introduce findbugs maven plugin

2016-08-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2422 Cool, thanks! The changes in the code look good. Give us a bit of time to play with the build and the findbugs output to get a better feeling for this... --- If your project is set up f

[jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445774#comment-15445774 ] ASF GitHub Bot commented on FLINK-4499: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2422: FLINK-4499: [WIP] Introduce findbugs maven plugin

2016-08-29 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2422 /cc @rmetzger FYI --- 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,

[jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445787#comment-15445787 ] ASF GitHub Bot commented on FLINK-4499: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

2016-08-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445795#comment-15445795 ] Robert Metzger commented on FLINK-3679: --- Two users were affected by this recently: h

[GitHub] flink issue #2422: FLINK-4499: [WIP] Introduce findbugs maven plugin

2016-08-29 Thread smarthi
Github user smarthi commented on the issue: https://github.com/apache/flink/pull/2422 Sure. I tried to exclude the most obvious false negatives but didn't go to the full extent. Hopefully this is a good place to start. --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin

2016-08-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445804#comment-15445804 ] ASF GitHub Bot commented on FLINK-4499: --- Github user smarthi commented on the issue:

[GitHub] flink pull request #:

2016-08-29 Thread tzulitai
Github user tzulitai commented on the pull request: https://github.com/apache/flink/commit/7b574cf5b6e7549ae53ea0846022c4430a979a01#commitcomment-18811598 From the original Kinesis consumer documentation, I don't think it's necessary to mention this, because there's already this in th

[GitHub] flink pull request #:

2016-08-29 Thread tzulitai
Github user tzulitai commented on the pull request: https://github.com/apache/flink/commit/7b574cf5b6e7549ae53ea0846022c4430a979a01#commitcomment-18811645 AFAIK, the original issue reporters set the parallelism to the number of Kinesis shards because they realized only then will the c

[GitHub] flink pull request #2434: [FLINK-4496] Refactor the TimeServiceProvider to t...

2016-08-29 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/2434 [FLINK-4496] Refactor the TimeServiceProvider to take a Trigerable in… This is a first step towards https://issues.apache.org/jira/browse/FLINK-4329 R: @aljoscha @rmetzger You can merge th

[jira] [Commented] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

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

[jira] [Created] (FLINK-4526) ApplicationClient: remove redundant proxy messages

2016-08-29 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4526: - Summary: ApplicationClient: remove redundant proxy messages Key: FLINK-4526 URL: https://issues.apache.org/jira/browse/FLINK-4526 Project: Flink Is

  1   2   3   >