[jira] [Closed] (FLINK-4694) Add wait for termination function to RpcEndpoints

2016-10-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4694. Resolution: Fixed Added via f863d16860be24ab6932282db0722eadc51b64a6 > Add wait for termination

[GitHub] flink pull request #2558: [FLINK-4694] [rpc] Add termination futures to RpcE...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2558 --- 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-4694) Add wait for termination function to RpcEndpoints

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

[jira] [Commented] (FLINK-4799) Re-add build-target symlink to project root

2016-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565507#comment-15565507 ] ASF GitHub Bot commented on FLINK-4799: --- Github user uce commented on the issue:

[GitHub] flink issue #2608: [FLINK-4512] [FLIP-10] Add option to persist periodic che...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2608 Tested the changes locally. I took a savepoint with and without explicit savepoint directory and resumed from there. Both seemed to work without a problem :-) --- If your project is set up

[GitHub] flink pull request #2621: [FLINK-4793] [types] Improve lambda constructor re...

2016-10-11 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2621#discussion_r82807840 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java --- @@ -0,0 +1,167 @@ +/* + * Licensed to the

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

2016-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565648#comment-15565648 ] ASF GitHub Bot commented on FLINK-2608: --- GitHub user chermenin opened a pull request:

[GitHub] flink pull request #2623: [FLINK-2608] Updated Twitter Chill version.

2016-10-11 Thread chermenin
GitHub user chermenin opened a pull request: https://github.com/apache/flink/pull/2623 [FLINK-2608] Updated Twitter Chill version. Fixed JIRA issue [[FLINK-2608] Arrays.asList(..) does not work with CollectionInputFormat](https://issues.apache.org/jira/browse/FLINK-2608) as issue

[jira] [Commented] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

2016-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565600#comment-15565600 ] ASF GitHub Bot commented on FLINK-3706: --- Github user rmetzger commented on the issue:

[jira] [Commented] (FLINK-4717) Naive version of atomic stop signal with savepoint

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

[GitHub] flink pull request #2609: [FLINK-4717] Add CancelJobWithSavepoint

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2609#discussion_r82814608 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -581,6 +581,62 @@ class JobManager( )

[GitHub] flink pull request #2594: [FLINK-4738] [TaskManager] Port TaskManager logic ...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2594 --- 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] [Closed] (FLINK-4738) Port TaskManager logic to TaskExecutor

2016-10-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4738. Resolution: Fixed Added via 8c656d9252fd01ea82c75ff1ea830b110f68f8a9 > Port TaskManager logic to

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

2016-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565759#comment-15565759 ] ASF GitHub Bot commented on FLINK-2608: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

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

[GitHub] flink pull request #2621: [FLINK-4793] [types] Improve lambda constructor re...

2016-10-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2621#discussion_r82828661 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java --- @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-4800) Refactor the ContinuousFileMonitoringFunction code and the related tests.

2016-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565554#comment-15565554 ] ASF GitHub Bot commented on FLINK-4800: --- Github user kl0u commented on the issue:

[GitHub] flink issue #2620: [FLINK-4799] re-add 'build-target' symlink on Unix system...

2016-10-11 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2620 Nice one, +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 enabled and

[GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl...

2016-10-11 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2425 I'll take a look. --- 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-3930) Implement Service-Level Authorization

2016-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565625#comment-15565625 ] ASF GitHub Bot commented on FLINK-3930: --- Github user rmetzger commented on the issue:

[jira] [Commented] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

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

[GitHub] flink pull request #2621: [FLINK-4793] [types] Improve lambda constructor re...

2016-10-11 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2621#discussion_r82812545 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java --- @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

2016-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565744#comment-15565744 ] ASF GitHub Bot commented on FLINK-4771: --- Github user qingdao81 commented on the issue:

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

2016-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565575#comment-15565575 ] ASF GitHub Bot commented on FLINK-4512: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

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

[GitHub] flink pull request #2621: [FLINK-4793] [types] Improve lambda constructor re...

2016-10-11 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2621#discussion_r82808001 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java --- @@ -0,0 +1,167 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

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

[GitHub] flink pull request #2622: [FLINK-3706] Fix YARN test instability

2016-10-11 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2622#discussion_r82810425 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -670,11 +684,13 @@ public void run() {

[GitHub] flink pull request #2622: [FLINK-3706] Fix YARN test instability

2016-10-11 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2622#discussion_r82809975 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -599,15 +602,23 @@ protected void runWithArgs(String[] args, String

[GitHub] flink pull request #2622: [FLINK-3706] Fix YARN test instability

2016-10-11 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2622#discussion_r82809384 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -599,15 +602,23 @@ protected void runWithArgs(String[] args, String

[jira] [Commented] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

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

[jira] [Commented] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

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

[jira] [Commented] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

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

[GitHub] flink pull request #2622: [FLINK-3706] Fix YARN test instability

2016-10-11 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2622#discussion_r82809706 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java --- @@ -621,13 +632,16 @@ protected static void sendOutput() {

[GitHub] flink issue #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-11 Thread qingdao81
Github user qingdao81 commented on the issue: https://github.com/apache/flink/pull/2612 Thanks for the review @fhueske I implemented the changes you requested. Not sure if the Codec enum in AvroOutputFormat is the best solution because its an additional wrapper around the avro

[GitHub] flink issue #2623: [FLINK-2608] Updated Twitter Chill version.

2016-10-11 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2623 Could you include a simple test to verify that this does in fact fix the issue? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

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

[GitHub] flink issue #2622: [FLINK-3706] Fix YARN test instability

2016-10-11 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2622 We should backport the fix to the `release-1.1` branch as well. --- 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

[GitHub] flink pull request #2621: [FLINK-4793] [types] Improve lambda constructor re...

2016-10-11 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2621#discussion_r82827707 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java --- @@ -0,0 +1,167 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4799) Re-add build-target symlink to project root

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

[jira] [Resolved] (FLINK-959) Automated bare-metal deployment of FLINK on Amazon EC2 and OpenStack instances

2016-10-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-959. -- Resolution: Invalid > Automated bare-metal deployment of FLINK on Amazon EC2 and OpenStack

[jira] [Commented] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

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

[GitHub] flink pull request #2618: Refactoring the Continuous File Monitoring Functio...

2016-10-11 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2618#discussion_r82813612 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java --- @@ -107,10 +113,10 @@

[GitHub] flink pull request #2609: [FLINK-4717] Add CancelJobWithSavepoint

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2609#discussion_r82805867 --- Diff: docs/setup/cli.md --- @@ -113,6 +113,10 @@ The command line can be used to ./bin/flink cancel +- Cancel a job

[jira] [Commented] (FLINK-4717) Naive version of atomic stop signal with savepoint

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

[jira] [Commented] (FLINK-4738) Port TaskManager logic to TaskExecutor

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

[jira] [Commented] (FLINK-959) Automated bare-metal deployment of FLINK on Amazon EC2 and OpenStack instances

2016-10-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565615#comment-15565615 ] Robert Metzger commented on FLINK-959: -- No, this issue is very outdated. I'll close it. > Automated

[jira] [Commented] (FLINK-4746) Replace TaskManagerRuntimeInfo by TaskManagerConfiguration

2016-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565115#comment-15565115 ] ASF GitHub Bot commented on FLINK-4746: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2599: [FLINK-4746] Make TaskManagerRuntimeInfo an interface

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2599 Rebasing this PR. If Travis gives green light, then I'll merge the PR. --- 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-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[GitHub] flink pull request #:

2016-10-11 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/commit/6731ec1e48d0a0092dd2330adda73bcf37fda8d7#commitcomment-19376002 In

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

2016-10-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565424#comment-15565424 ] Robert Metzger commented on FLINK-3704: --- So this is a bug in curator, not reporting errors

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-10-11 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565447#comment-15565447 ] Timo Walther commented on FLINK-4743: - Power can basically express both. I would just implement power

[GitHub] flink issue #2620: [FLINK-4799] re-add 'build-target' symlink on Unix system...

2016-10-11 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2620 Thank you very much for this! Just tested this on OS X and it works as expected when packaging and cleaning. +1 to merge this. --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82777602 --- Diff: flink-runtime-web/web-dashboard/app/scripts/index.coffee --- @@ -29,8 +29,8 @@ angular.module('flinkApp', ['ui.router', 'angularMoment'])

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82796670 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointStore.java --- @@ -18,23 +18,105 @@ package

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82786136 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java --- @@ -233,68 +229,90 @@ public int

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82799818 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/messages/JobManagerMessages.scala --- @@ -467,8 +467,11 @@ object JobManagerMessages {

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82778103 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -219,33 +245,9 @@ public

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82783495 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java --- @@ -256,29 +306,51 @@ public boolean

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82778433 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -282,29 +279,71 @@ public boolean

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82781804 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java --- @@ -51,9 +57,11 @@ /** States of the

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82796870 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointStore.java --- @@ -43,24 +125,62 @@ * @return The

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82781688 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java --- @@ -18,44 +18,243 @@ package

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82787864 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointLoader.java --- @@ -48,13 +48,12 @@ public static

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82778557 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -282,29 +279,71 @@ public boolean

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82776861 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -637,20 +637,25 @@ protected int savepoint(String[] args) {

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82797030 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointStore.java --- @@ -43,24 +125,62 @@ * @return The

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82784524 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StandaloneCompletedCheckpointStore.java --- @@ -64,9 +62,9 @@ public void

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82784661 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StandaloneCompletedCheckpointStore.java --- @@ -64,9 +62,9 @@ public void

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2608#discussion_r82782971 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java --- @@ -51,9 +57,11 @@ /** States of the

[GitHub] flink pull request #2620: [FLINK-4799] re-add 'build-target' symlink on Unix...

2016-10-11 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2620 [FLINK-4799] re-add 'build-target' symlink on Unix systems This adds back the link 'build-target' which points to the final build assembly in 'flink-dist/target/...'. The link is only created on Unix

[GitHub] flink issue #2618: Refactoring the Continuous File Monitoring Function.

2016-10-11 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2618 Thanks @rmetzger ! This is the issue: https://issues.apache.org/jira/browse/FLINK-4800 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Created] (FLINK-4800) Refactor the ContinuousFileMonitoringFunction code and the related tests.

2016-10-11 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4800: - Summary: Refactor the ContinuousFileMonitoringFunction code and the related tests. Key: FLINK-4800 URL: https://issues.apache.org/jira/browse/FLINK-4800 Project:

[GitHub] flink issue #2620: [FLINK-4799] re-add 'build-target' symlink on Unix system...

2016-10-11 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2620 +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 enabled and wishes so, or if

[jira] [Commented] (FLINK-4799) Re-add build-target symlink to project root

2016-10-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565515#comment-15565515 ] ASF GitHub Bot commented on FLINK-4799: --- Github user rmetzger commented on the issue:

[GitHub] flink pull request #:

2016-10-11 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/commit/6731ec1e48d0a0092dd2330adda73bcf37fda8d7#commitcomment-19376219 In

[GitHub] flink pull request #:

2016-10-11 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/commit/6731ec1e48d0a0092dd2330adda73bcf37fda8d7#commitcomment-19376443 In

[GitHub] flink pull request #:

2016-10-11 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/commit/6731ec1e48d0a0092dd2330adda73bcf37fda8d7#commitcomment-19376877 In

[jira] [Commented] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

2016-10-11 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565341#comment-15565341 ] Timo Walther commented on FLINK-4793: - I found another bug that I will fix in a upcoming PR. Now this

[GitHub] flink pull request #2621: [FLINK-4793] [types] Improve lambda constructor re...

2016-10-11 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2621 [FLINK-4793] [types] Improve lambda constructor reference handling Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[GitHub] flink pull request #2622: [FLINK-3706] Fix YARN test instability

2016-10-11 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/2622 [FLINK-3706] Fix YARN test instability The most important change in this commit is that the `YarnTestBase.Runner` doesn't do `try {} catch (Throwable t) { fail(t); }` anymore, which doesn't lead

[jira] [Commented] (FLINK-4793) Using a local method with :: notation in Java 8 causes index out of bounds

2016-10-11 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565337#comment-15565337 ] Timo Walther commented on FLINK-4793: - [~tdunning] which Flink version are you using? Your issue might

  1   2   >