[jira] [Commented] (FLINK-4460) Side Outputs in Flink

2017-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906129#comment-15906129 ] ASF GitHub Bot commented on FLINK-4460: --- Github user kl0u commented on the issue:

[GitHub] flink issue #3484: [FLINK-4460] Side Outputs in Flink

2017-03-11 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3484 Thanks @aljoscha I will have a look on Monday. --- 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

[GitHub] flink issue #3445: [FLINK-5846] [cep] Make the CEP operators backwards compa...

2017-03-11 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3445 @aljoscha , I integrated your comments. --- 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

[jira] [Commented] (FLINK-5846) CEP: make the operators backwards compatible.

2017-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906132#comment-15906132 ] ASF GitHub Bot commented on FLINK-5846: --- Github user kl0u commented on the issue:

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-11 Thread Wei-Che Wei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906135#comment-15906135 ] Wei-Che Wei commented on FLINK-5982: I see. I will just focus on refactoring {{setEnvi

[GitHub] flink issue #3406: [flink-5568] [Table API & SQL]Introduce interface for cat...

2017-03-11 Thread beyond1920
Github user beyond1920 commented on the issue: https://github.com/apache/flink/pull/3406 @fhueske , thanks for your review. I updated the pr based on your comments. Your suggestion about moving the annotation from TableSource to TableSourceConverter is good, I changed the pr in thi

[jira] [Created] (FLINK-6025) User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying

2017-03-11 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6025: -- Summary: User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying Key: FLINK-6025 URL: https://issues.apache.org/jira/browse/FLINK-602

[jira] [Updated] (FLINK-6025) User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying

2017-03-11 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6025: --- Description: Reported in ML: http://apache-flink-user-mailing-list-archive.2336050.n4

[jira] [Updated] (FLINK-6025) User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying

2017-03-11 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6025: --- Description: Reported in ML: http://apache-flink-user-mailing-list-archive.2336050.n4

[GitHub] flink issue #3374: [FLINK-4754] [checkpoints] Make number of retained checkp...

2017-03-11 Thread tony810430
Github user tony810430 commented on the issue: https://github.com/apache/flink/pull/3374 Hi @StephanEwen Thank you for the review. I have rebased and done those improvements in your suggestion. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-4754) Make number of retained checkpoints user configurable

2017-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906193#comment-15906193 ] ASF GitHub Bot commented on FLINK-4754: --- Github user tony810430 commented on the iss

[GitHub] flink pull request #3515: [FLINK-5890] [gelly] GatherSumApply broken when ob...

2017-03-11 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3515 [FLINK-5890] [gelly] GatherSumApply broken when object reuse enabled The initial fix for this ticket is not working on larger data sets. Reduce supports returning the left input, right inp

[jira] [Commented] (FLINK-5890) GatherSumApply broken when object reuse enabled

2017-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906198#comment-15906198 ] ASF GitHub Bot commented on FLINK-5890: --- GitHub user greghogan opened a pull request

[GitHub] flink issue #3515: [FLINK-5890] [gelly] GatherSumApply broken when object re...

2017-03-11 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3515 @StephanEwen deja vu FLINK-2883 / FLINK-3340. I'm also looking to run the FLINK-4949 IT tests with object reuse both enabled and disabled which would have highlighted this issue as the unit

[jira] [Commented] (FLINK-5890) GatherSumApply broken when object reuse enabled

2017-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906199#comment-15906199 ] ASF GitHub Bot commented on FLINK-5890: --- Github user greghogan commented on the issu

[jira] [Reopened] (FLINK-5890) GatherSumApply broken when object reuse enabled

2017-03-11 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reopened FLINK-5890: --- See #3515 > GatherSumApply broken when object reuse enabled > ---

[jira] [Commented] (FLINK-6009) Deprecate DataSetUtils#checksumHashCode

2017-03-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906201#comment-15906201 ] ASF GitHub Bot commented on FLINK-6009: --- GitHub user greghogan opened a pull request

[GitHub] flink pull request #3516: [FLINK-6009] [java api] Deprecate DataSetUtils#che...

2017-03-11 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3516 [FLINK-6009] [java api] Deprecate DataSetUtils#checksumHashCode This is likely only used by Gelly and we have a more featureful implementation allowing for multiple outputs and setting the job nam

[jira] [Updated] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

2017-03-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-5855: -- Description: {code} handlePendingFilesForPreviousCheckpoints(restoredState.pendingFilesPerCheckpoint);

[jira] [Updated] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions

2017-03-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-5488: -- Description: Here is one example: {code} if(jobManagerMemoryMb > maxRes.getMemory() ) { failSessionDur

[jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

2017-03-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4534: -- Description: Iteration over state.bucketStates is protected by synchronization in other methods, except for the