[jira] [Commented] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140460#comment-15140460 ] ASF GitHub Bot commented on FLINK-2991: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-2991] Add Folding State and use in Wind...

2016-02-09 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1605#issuecomment-182237986 I'll add doc and also fix some other stuff in the doc that wasn't updated. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-3035) Redis as State Backend

2016-02-09 Thread Subhobrata Dey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15140239#comment-15140239 ] Subhobrata Dey commented on FLINK-3035: --- Hello [~mjsax] Thanks for replying. I adopt

[GitHub] flink pull request: [FLINK-3035] Redis as State Backend

2016-02-09 Thread sbcd90
GitHub user sbcd90 opened a pull request: https://github.com/apache/flink/pull/1617 [FLINK-3035] Redis as State Backend @mjsax please review. You can merge this pull request into a Git repository by running: $ git pull https://github.com/sbcd90/flink FLINK-3035 Alternatively y

[jira] [Commented] (FLINK-3035) Redis as State Backend

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

[jira] [Commented] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation

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

[GitHub] flink pull request: [FLINK-2991] Add Folding State and use in Wind...

2016-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1605#issuecomment-182125713 You are adding new `.apply()` variants to the API which are not documented with the PR. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139953#comment-15139953 ] ASF GitHub Bot commented on FLINK-2523: --- Github user kl0u commented on a diff in the

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/1612#discussion_r52388927 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java --- @@ -102,60 +101,150 @@ //

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/1612#discussion_r52388853 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java --- @@ -102,60 +101,150 @@ //

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139951#comment-15139951 ] ASF GitHub Bot commented on FLINK-2523: --- Github user kl0u commented on a diff in the

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139949#comment-15139949 ] ASF GitHub Bot commented on FLINK-2523: --- Github user kl0u commented on a diff in the

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/1612#discussion_r52388830 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java --- @@ -102,60 +101,150 @@ //

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139942#comment-15139942 ] ASF GitHub Bot commented on FLINK-2523: --- Github user kl0u commented on a diff in the

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/1612#discussion_r52388350 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java --- @@ -141,9 +146,16 @@ public TaskDeploymentDescriptor

[GitHub] flink pull request: [FLINK-2991] Add Folding State and use in Wind...

2016-02-09 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1605#discussion_r52388115 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBFoldingState.java --- @@ -0,0 +1,175 @@

[jira] [Commented] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation

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

[jira] [Commented] (FLINK-3366) Rename @Experimental annotation to @PublicEvolving

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

[GitHub] flink pull request: [FLINK-3366] Rename @Experimental annotation t...

2016-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1599#issuecomment-182115171 +1 to merge --- 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 e

[jira] [Commented] (FLINK-3372) Setting custom YARN application name is ignored

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

[GitHub] flink pull request: [FLINK-3372] Setting custom YARN application n...

2016-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1607#issuecomment-182114169 +1 to merge --- 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 e

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1612#discussion_r52385698 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java --- @@ -141,9 +146,16 @@ public TaskDeploymentDescri

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1612#discussion_r52385188 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java --- @@ -75,16 +76,22 @@ public void te

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

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

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1612#discussion_r52386295 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java --- @@ -102,60 +101,150 @@ //

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1612#discussion_r52385934 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java --- @@ -102,60 +101,150 @@ //

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1612#discussion_r52386582 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java --- @@ -102,60 +101,150 @@ //

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1612#discussion_r52385415 --- Diff: docs/apis/batch/index.md --- @@ -2123,7 +2123,7 @@ Note that types registered with `registerKryoType()` are not available to Flink' - `d

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1612#discussion_r52385223 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java --- @@ -27,13 +24,17 @@ import or

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

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

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

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

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

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

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

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

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

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

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

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

[GitHub] flink pull request: FLINK-2380: allow to specify the default files...

2016-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1524#issuecomment-182054657 I'm testing the change on a cluster (with YARN) to see if everything is working as expected. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs

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

[GitHub] flink pull request: FLINK-2380: allow to specify the default files...

2016-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1524#issuecomment-182066864 Setting the value to `fs.default-scheme: thisIsWrong:///` is good: ``` robert@cdh544-master:~/flink/build-target$ ./bin/flink run ./examples/batch/

[jira] [Commented] (FLINK-3335) Fix DataSourceTask object reuse when disabled

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

[GitHub] flink pull request: [FLINK-3335] [runtime] Fix DataSourceTask obje...

2016-02-09 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1616 [FLINK-3335] [runtime] Fix DataSourceTask object reuse when disabled When object reuse is disabled, `DataSourceTask` now copies objects received from the `InputFormat` to prevent the collection of

[jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs

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

[GitHub] flink pull request: FLINK-2380: allow to specify the default files...

2016-02-09 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1524#issuecomment-182065768 I identified the following issues: - Setting the configuration using the yarn session "dynamic properties": `./bin/yarn-session.sh -n 2 -Dfs.default-scheme=hdfs

[jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs

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

[jira] [Commented] (FLINK-3260) ExecutionGraph gets stuck in state FAILING

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

[jira] [Commented] (FLINK-3260) ExecutionGraph gets stuck in state FAILING

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

[GitHub] flink pull request: [FLINK-3260] [runtime] Enforce terminal state ...

2016-02-09 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1613#issuecomment-182046481 Looks good, with one inline comment. Otherwise, +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request: [FLINK-3260] [runtime] Enforce terminal state ...

2016-02-09 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1613#discussion_r52368138 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java --- @@ -107,7 +108,7 @@ private static final AtomicR

[jira] [Commented] (FLINK-3373) Using a newer library of Apache HttpClient than 4.2.6 will get class loading problems

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139694#comment-15139694 ] ASF GitHub Bot commented on FLINK-3373: --- GitHub user StephanEwen opened a pull reque

[GitHub] flink pull request: [FLINK-3373] [build] Shade away Hadoop's HTTP ...

2016-02-09 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1615 [FLINK-3373] [build] Shade away Hadoop's HTTP Components dependency This makes the HTTP Components dependency disappear from the core classpath, allowing users to use their own version of the de

[jira] [Commented] (FLINK-3333) Documentation about object reuse should be improved

2016-02-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139668#comment-15139668 ] Greg Hogan commented on FLINK-: --- I can think of four return values from a user defin

[jira] [Comment Edited] (FLINK-3333) Documentation about object reuse should be improved

2016-02-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139151#comment-15139151 ] Greg Hogan edited comment on FLINK- at 2/9/16 8:07 PM: --- Apac

[jira] [Closed] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper

2016-02-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3382. - Resolution: Not A Problem Per the comment on the pull request, this change would interfere with proper us

[jira] [Commented] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper

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

[GitHub] flink pull request: [FLINK-3382] Improve clarity of object reuse i...

2016-02-09 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1614#issuecomment-182035391 Ah, yes, now I see. I'll just burn this. --- 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 projec

[jira] [Commented] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139652#comment-15139652 ] ASF GitHub Bot commented on FLINK-3382: --- Github user greghogan commented on the pull

[GitHub] flink pull request: [FLINK-3382] Improve clarity of object reuse i...

2016-02-09 Thread greghogan
Github user greghogan closed the pull request at: https://github.com/apache/flink/pull/1614 --- 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: [FLINK-3382] Improve clarity of object reuse i...

2016-02-09 Thread ggevay
Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/1614#issuecomment-182025617 Shouldn't the current record remain valid if `hasNext()` returned true? I mean the user might be holding on to the object returned in `next`, and expect it to not be chan

[jira] [Commented] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139530#comment-15139530 ] ASF GitHub Bot commented on FLINK-3382: --- Github user ggevay commented on the pull re

[jira] [Commented] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper

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

[GitHub] flink pull request: [FLINK-3382] Improve clarity of object reuse i...

2016-02-09 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1614 [FLINK-3382] Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper You can merge this pull request into a Git repository by running: $ git pull https://github.com/gregho

[jira] [Commented] (FLINK-3333) Documentation about object reuse should be improved

2016-02-09 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139435#comment-15139435 ] Gabor Gevay commented on FLINK-: One more thing: if we decide to go with including

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139415#comment-15139415 ] ASF GitHub Bot commented on FLINK-2523: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1612#discussion_r52356401 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java --- @@ -102,60 +101,150 @@ //

[jira] [Updated] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper

2016-02-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3382: -- Description: Object reuse in {{ReusingMutableToRegularIteratorWrapper.hasNext()}} can be clarified by c

[jira] [Updated] (FLINK-3335) Fix DataSourceTask object reuse when disabled

2016-02-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3335: -- Summary: Fix DataSourceTask object reuse when disabled (was: DataSourceTask object reuse when disabled)

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139332#comment-15139332 ] ASF GitHub Bot commented on FLINK-3226: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-3226] Translate logical aggregations to...

2016-02-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1600#discussion_r52349128 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AvgAggregate.scala --- @@ -0,0 +1,145 @@ +/* +

[jira] [Commented] (FLINK-3187) Decouple restart strategy from ExecutionGraph

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139297#comment-15139297 ] ASF GitHub Bot commented on FLINK-3187: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-3187] Introduce RestartStrategy to deco...

2016-02-09 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1470#issuecomment-181981959 If nobody objects, then I would like to merge this PR, since it will give us more flexibility in the future with respect to restarting strategies. --- If your proj

[GitHub] flink pull request: [FLINK-3260] [runtime] Enforce terminal state ...

2016-02-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1613 [FLINK-3260] [runtime] Enforce terminal state of Executions This commit fixes the problem that Executions could leave their terminal state FINISHED to transition to FAILED. Such a transitio

[jira] [Commented] (FLINK-3260) ExecutionGraph gets stuck in state FAILING

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139293#comment-15139293 ] ASF GitHub Bot commented on FLINK-3260: --- GitHub user tillrohrmann opened a pull requ

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

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

[GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv...

2016-02-09 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/1612 FLINK-2523: Makes the task cancellation interval configurable. You can merge this pull request into a Git repository by running: $ git pull https://github.com/kl0u/flink task_cancellation_interva

[jira] [Created] (FLINK-3383) Separate Maven deployment from CI testing

2016-02-09 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3383: - Summary: Separate Maven deployment from CI testing Key: FLINK-3383 URL: https://issues.apache.org/jira/browse/FLINK-3383 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3333) Documentation about object reuse should be improved

2016-02-09 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139219#comment-15139219 ] Gabor Gevay commented on FLINK-: OK, this would also be a clear improvement over t

[GitHub] flink pull request: [FLINK-3226] Implement a CodeGenerator for an ...

2016-02-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1595#issuecomment-181955939 Thanks for the quick update @twalthr! Some tests are failing because the wrong type of exception is expected. I'll fix those and then merge this. --- If your project is s

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139202#comment-15139202 ] ASF GitHub Bot commented on FLINK-3226: --- Github user vasia commented on the pull req

[jira] [Updated] (FLINK-3380) Unstable Test: JobSubmissionFailsITCase

2016-02-09 Thread Klou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Klou updated FLINK-3380: Description: https://s3.amazonaws.com/archive.travis-ci.org/jobs/108034635/log.txt (was: {quote} Tests run: 7, Fai

[GitHub] flink pull request: FLINK-3271: Include jetty-util in the dist jar

2016-02-09 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1543#discussion_r52336491 --- Diff: flink-shaded-hadoop/pom.xml --- @@ -111,6 +111,7 @@ under the License. i

[jira] [Commented] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception

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

[jira] [Created] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper

2016-02-09 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3382: - Summary: Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper Key: FLINK-3382 URL: https://issues.apache.org/jira/browse/FLINK-3382 Project: Flink

[jira] [Created] (FLINK-3381) Unstable Test: JobManagerSubmittedJobGraphsRecoveryITCase

2016-02-09 Thread Klou (JIRA)
Klou created FLINK-3381: --- Summary: Unstable Test: JobManagerSubmittedJobGraphsRecoveryITCase Key: FLINK-3381 URL: https://issues.apache.org/jira/browse/FLINK-3381 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-3380) Unstable Test: JobSubmissionFailsITCase

2016-02-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139190#comment-15139190 ] Ufuk Celebi commented on FLINK-3380: These should be fixed with https://github.com/apa

[jira] [Created] (FLINK-3380) Unstable Test: JobSubmissionFailsITCase

2016-02-09 Thread Klou (JIRA)
Klou created FLINK-3380: --- Summary: Unstable Test: JobSubmissionFailsITCase Key: FLINK-3380 URL: https://issues.apache.org/jira/browse/FLINK-3380 Project: Flink Issue Type: Bug Reporter: Klo

[jira] [Commented] (FLINK-3375) Allow Watermark Generation in the Kafka Source

2016-02-09 Thread Zach Cox (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139159#comment-15139159 ] Zach Cox commented on FLINK-3375: - Like [~shikhar] I will also have event producers on dif

[jira] [Commented] (FLINK-3333) Documentation about object reuse should be improved

2016-02-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139151#comment-15139151 ] Greg Hogan commented on FLINK-: --- Apache Flink programs can be written and configured

[jira] [Commented] (FLINK-3333) Documentation about object reuse should be improved

2016-02-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139150#comment-15139150 ] Greg Hogan commented on FLINK-: --- I think it is most important that the user document

[GitHub] flink pull request: FLINK-3271: Include jetty-util in the dist jar

2016-02-09 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/flink/pull/1543#discussion_r52330385 --- Diff: flink-shaded-hadoop/flink-shaded-hadoop2/pom.xml --- @@ -184,10 +184,10 @@ under the License. org.m

[jira] [Commented] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139132#comment-15139132 ] ASF GitHub Bot commented on FLINK-3271: --- Github user abhishekagarwal87 commented on

[GitHub] flink pull request: FLINK-3271: Include jetty-util in the dist jar

2016-02-09 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/flink/pull/1543#discussion_r52330359 --- Diff: flink-shaded-hadoop/pom.xml --- @@ -111,6 +111,7 @@ under the License.

[jira] [Commented] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139131#comment-15139131 ] ASF GitHub Bot commented on FLINK-3271: --- Github user abhishekagarwal87 commented on

[jira] [Comment Edited] (FLINK-3356) JobClientActorRecoveryITCase.testJobClientRecovery

2016-02-09 Thread Klou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139116#comment-15139116 ] Klou edited comment on FLINK-3356 at 2/9/16 4:14 PM: - Although it does

[jira] [Commented] (FLINK-3105) Submission in per job YARN cluster mode reuses properties file of long-lived session

2016-02-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139129#comment-15139129 ] Ufuk Celebi commented on FLINK-3105: Do we want to fix this for 1.0? > Submission in

[jira] [Updated] (FLINK-3105) Submission in per job YARN cluster mode reuses properties file of long-lived session

2016-02-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-3105: --- Fix Version/s: (was: 0.10.2) > Submission in per job YARN cluster mode reuses properties file of l

[GitHub] flink pull request: Increase test timeouts

2016-02-09 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/1611 Increase test timeouts - Increases Akka ask timeout in test clusters. Because there is no clear hierarchy with these, I added a `setDefaultCiConfig(Configuration` method to `FlinkMiniCluster`, which is

[jira] [Commented] (FLINK-3356) JobClientActorRecoveryITCase.testJobClientRecovery

2016-02-09 Thread Klou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139116#comment-15139116 ] Klou commented on FLINK-3356: - More unstable tests (timeouts seem to be the reason) https://

[jira] [Commented] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception

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

[GitHub] flink pull request: FLINK-3271: Include jetty-util in the dist jar

2016-02-09 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1543#discussion_r52328751 --- Diff: flink-shaded-hadoop/pom.xml --- @@ -111,6 +111,7 @@ under the License. i

[jira] [Commented] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception

2016-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15139108#comment-15139108 ] ASF GitHub Bot commented on FLINK-3271: --- Github user abhishekagarwal87 commented on

[GitHub] flink pull request: FLINK-3271: Include jetty-util in the dist jar

2016-02-09 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/flink/pull/1543#discussion_r52327591 --- Diff: flink-shaded-hadoop/pom.xml --- @@ -111,6 +111,7 @@ under the License.

  1   2   3   >