[jira] [Commented] (FLINK-8596) Custom command line code does not correctly catch errors

2018-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372533#comment-16372533 ] ASF GitHub Bot commented on FLINK-8596: --- Github user zentol commented on the issue:

[GitHub] flink issue #5543: [FLINK-8596][CLI] Also catch NoClassDefFoundErrors

2018-02-22 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5543 E2E test isn't fully working yet, debugging... ---

[jira] [Closed] (FLINK-8705) Integrate Remote(Stream)Environment with Flip-6 cluster

2018-02-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8705. Resolution: Fixed Fixed via facf2ac67ae3ffd4cffd7c6f8536fd7953795fb9

[jira] [Resolved] (FLINK-8711) Flink with YARN uses wrong SlotsPerTaskManager

2018-02-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8711. -- Resolution: Fixed Fix Version/s: 1.5.0 Fixed via 

[jira] [Closed] (FLINK-8632) Generalize SavepointHandlers to be used for other asynchronous operations

2018-02-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8632. Resolution: Fixed Fixed via 831349a617d2bd3b9be6d3c1ca777baa25276c88 > Generalize

[jira] [Closed] (FLINK-8631) Add support for generic response types to RestClient

2018-02-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8631. Resolution: Fixed Fixed via 313284f535bc84ca3f47bdb07f0553fe3326f70c > Add support for generic

[jira] [Created] (FLINK-8743) Add annotation to override documented default

2018-02-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8743: --- Summary: Add annotation to override documented default Key: FLINK-8743 URL: https://issues.apache.org/jira/browse/FLINK-8743 Project: Flink Issue

[jira] [Resolved] (FLINK-7712) Port JarDeleteHandler to new REST endpoint

2018-02-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7712. -- Resolution: Fixed Added via 0db9c5bc3d3f61a3af3a94281ed2bf580007b873 > Port JarDeleteHandler

[jira] [Resolved] (FLINK-7714) Port JarPlanHandler to new REST endpoint

2018-02-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7714. -- Resolution: Fixed Added via 46e6d483c63caad90dbe8f6bc50049c001f74edc > Port JarPlanHandler to

[jira] [Resolved] (FLINK-8710) AbstractYarnClusterDescriptor doesn't use pre-defined configs in Hadoop's YarnConfiguration

2018-02-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8710. -- Resolution: Fixed Fixed via d3114cd90d99bb11f1f55b5d5ad0576527541b41 >

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

2018-02-22 Thread chris snow (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372534#comment-16372534 ] chris snow commented on FLINK-8543: ---   [~aljoscha] - what are your thoughts on this?  > Output Stream

[jira] [Created] (FLINK-8741) KafkaFetcher09/010/011 uses wrong user code classloader

2018-02-22 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-8741: -- Summary: KafkaFetcher09/010/011 uses wrong user code classloader Key: FLINK-8741 URL: https://issues.apache.org/jira/browse/FLINK-8741 Project: Flink

[jira] [Created] (FLINK-8742) Move ConfigDocsGenerator annotationt to flink-annotations

2018-02-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8742: --- Summary: Move ConfigDocsGenerator annotationt to flink-annotations Key: FLINK-8742 URL: https://issues.apache.org/jira/browse/FLINK-8742 Project: Flink

[jira] [Created] (FLINK-8744) Add annotations for documentation common/advanced options

2018-02-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8744: --- Summary: Add annotations for documentation common/advanced options Key: FLINK-8744 URL: https://issues.apache.org/jira/browse/FLINK-8744 Project: Flink

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r169899133 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java --- @@ -0,0 +1,172 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

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

[GitHub] flink pull request #5552: [FLINK-8735] Add new StatefulJobSavepointMigration...

2018-02-22 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5552#discussion_r169918501 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java --- @@ -0,0 +1,658 @@ +/* +

[GitHub] flink pull request #5552: [FLINK-8735] Add new StatefulJobSavepointMigration...

2018-02-22 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5552#discussion_r169918485 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java --- @@ -0,0 +1,658 @@ +/* +

[jira] [Commented] (FLINK-8735) Add savepoint migration ITCase that covers operator state

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

[jira] [Commented] (FLINK-8735) Add savepoint migration ITCase that covers operator state

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

[jira] [Updated] (FLINK-8740) Job-level metrics lost during job re-submission in HA mode

2018-02-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8740: Priority: Blocker (was: Major) > Job-level metrics lost during job re-submission in HA

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169632755 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/RescalingBehaviour.java --- @@ -0,0 +1,49 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169917845 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -447,6 +453,165 @@ public void postStop() throws Exception {

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169917224 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -447,6 +453,165 @@ public void postStop() throws Exception {

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169911850 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -447,6 +453,165 @@ public void postStop() throws Exception {

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169919835 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/RescaleParallelismQueryParameter.java --- @@ -0,0 +1,41 @@ +/* + *

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169918052 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -447,6 +453,165 @@ public void postStop() throws Exception {

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169916387 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -447,6 +453,165 @@ public void postStop() throws Exception {

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169913228 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -963,6 +1120,36 @@ private Acknowledge suspendExecution(final

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169920801 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/RescalingStatusMessageParameters.java --- @@ -0,0 +1,39 @@ +/* + *

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169912256 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -447,6 +453,165 @@ public void postStop() throws Exception {

[jira] [Updated] (FLINK-8742) Move ConfigDocsGenerator annotation to flink-annotations

2018-02-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8742: Summary: Move ConfigDocsGenerator annotation to flink-annotations (was: Move

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r169897306 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java --- @@ -0,0 +1,101 @@ +/* + * Licensed to the

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r169898758 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java --- @@ -0,0 +1,101 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r169898668 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java --- @@ -0,0 +1,172 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r169899631 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java --- @@ -0,0 +1,172 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r169909152 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java --- @@ -0,0 +1,172 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-8735) Add savepoint migration ITCase that covers operator state

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

[jira] [Commented] (FLINK-7944) Allow configuring Hadoop Classpath

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

[GitHub] flink pull request #4920: [FLINK-7944] Allow configuring Hadoop classpath

2018-02-22 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/4920 ---

[jira] [Commented] (FLINK-8735) Add savepoint migration ITCase that covers operator state

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

[GitHub] flink pull request #5552: [FLINK-8735] Add new StatefulJobSavepointMigration...

2018-02-22 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5552#discussion_r169919719 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java --- @@ -0,0 +1,658 @@ +/* +

[jira] [Commented] (FLINK-8744) Add annotations for documentation common/advanced options

2018-02-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372652#comment-16372652 ] Chesnay Schepler commented on FLINK-8744: - We can probably remove the advanced section if we move

[jira] [Commented] (FLINK-8735) Add savepoint migration ITCase that covers operator state

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

[GitHub] flink pull request #5552: [FLINK-8735] Add new StatefulJobSavepointMigration...

2018-02-22 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5552#discussion_r169919922 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java --- @@ -0,0 +1,658 @@ +/* +

[jira] [Commented] (FLINK-8735) Add savepoint migration ITCase that covers operator state

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

[jira] [Commented] (FLINK-8735) Add savepoint migration ITCase that covers operator state

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

[GitHub] flink pull request #5552: [FLINK-8735] Add new StatefulJobSavepointMigration...

2018-02-22 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5552#discussion_r169920122 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java --- @@ -0,0 +1,658 @@ +/* + *

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r169896622 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryKeyedStateHandle.java --- @@ -0,0 +1,105 @@ +/* + * Licensed

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r169896224 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStreamWithResultProvider.java --- @@ -172,4 +167,30 @@ public

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5518#discussion_r169905515 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java ---

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

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

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r169905650 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java --- @@ -0,0 +1,172 @@ +/* + * Licensed to the

[GitHub] flink issue #5545: [FLINK-8718][DataStream] Set maxParallelism on non-parall...

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5545 I agree with @aljoscha, there is a sanity check that `maxParallelism` of operators did not change when restoring. ---

[jira] [Commented] (FLINK-8718) Non-parallel DataStreamSource does not set max parallelism

2018-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372660#comment-16372660 ] ASF GitHub Bot commented on FLINK-8718: --- Github user StefanRRichter commented on the issue:

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r169895663 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r169895777 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[jira] [Commented] (FLINK-8744) Add annotations for documentation common/advanced options

2018-02-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372603#comment-16372603 ] Stephan Ewen commented on FLINK-8744: - IIRC, we initially had only "common" and "advanced" was the

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5518#discussion_r169904243 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java --- @@ -61,8 +61,9 @@ * over it

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[GitHub] flink issue #5545: [FLINK-8718][DataStream] Set maxParallelism on non-parall...

2018-02-22 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5545 Yes, no source can use keyed state. 😄 But the `StateAssignmentOperation` will still fail a restore if the `maxParallelism` of an operator changes. Maybe @StefanRRichter can chime in on that but

[jira] [Commented] (FLINK-8718) Non-parallel DataStreamSource does not set max parallelism

2018-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372641#comment-16372641 ] ASF GitHub Bot commented on FLINK-8718: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

2018-02-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372643#comment-16372643 ] Aljoscha Krettek commented on FLINK-8543: - The comments are correct, S3 simply does not support

[GitHub] flink pull request #5552: [FLINK-8735] Add new StatefulJobSavepointMigration...

2018-02-22 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5552#discussion_r169917696 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java --- @@ -0,0 +1,658 @@ +/* +

[GitHub] flink pull request #5552: [FLINK-8735] Add new StatefulJobSavepointMigration...

2018-02-22 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5552#discussion_r169919494 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java --- @@ -0,0 +1,658 @@ +/* +

[jira] [Commented] (FLINK-8735) Add savepoint migration ITCase that covers operator state

2018-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372664#comment-16372664 ] ASF GitHub Bot commented on FLINK-8735: --- Github user kl0u commented on the issue:

[GitHub] flink issue #5552: [FLINK-8735] Add new StatefulJobSavepointMigrationITCase

2018-02-22 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5552 I will have a look at the current state of the PR, but given that you started the effort, it would be good for completeness, to also refactor the `scala` equivalent `ITcase` to get rid of all the

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[jira] [Updated] (FLINK-8740) Job-level metrics lost during job re-submission in HA mode

2018-02-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8740: Fix Version/s: 1.5.0 > Job-level metrics lost during job re-submission in HA mode >

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169922284 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/RescaleParallelismQueryParameter.java --- @@ -0,0 +1,41 @@ +/* + *

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[jira] [Commented] (FLINK-8656) Add CLI command for rescaling

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

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169918959 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/AsynchronousOperationInfo.java --- @@ -0,0 +1,64 @@ +/* + * Licensed

[GitHub] flink pull request #5487: [FLINK-8656] [flip6] Add modify CLI command to res...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5487#discussion_r169634082 --- Diff: flink-core/src/main/java/org/apache/flink/util/function/BiConsumerWithException.java --- @@ -0,0 +1,50 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5518#discussion_r169946803 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java ---

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5518#discussion_r169948460 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBRocksIteratorWrapperTest.java

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

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

[GitHub] flink pull request #5548: [FLINK-8732] [flip6] Cancel ongoing scheduling ope...

2018-02-22 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5548#discussion_r169943180 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java --- @@ -377,14 +377,14 @@ public boolean scheduleForExecution() {

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

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

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

2018-02-22 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5518#discussion_r169949298 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java ---

  1   2   3   4   >