[jira] [Closed] (FLINK-8637) Pass JobManagerSharedServices to JobMaster

[ https://issues.apache.org/jira/browse/FLINK-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8637. Resolution: Fixed Fixed via 24c30878ed6f6ed1599a5ec23362055e0e88916f > Pass

[jira] [Commented] (FLINK-8637) Pass JobManagerSharedServices to JobMaster

[ https://issues.apache.org/jira/browse/FLINK-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361942#comment-16361942 ] ASF GitHub Bot commented on FLINK-8637: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5457: [FLINK-8637] [flip6] Use JobManagerSharedServices ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5457 ---

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361924#comment-16361924 ] Krzysztof Białek commented on FLINK-2366: - As an experiment I've implemented Flink HA on top of

[jira] [Closed] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default

[ https://issues.apache.org/jira/browse/FLINK-5728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-5728. -- Resolution: Won't Fix Fix Version/s: (was: 1.5.0) > FlinkKafkaProducer

[jira] [Commented] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default

[ https://issues.apache.org/jira/browse/FLINK-5728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361900#comment-16361900 ] Tzu-Li (Gordon) Tai commented on FLINK-5728: There was some discussion on the mailing list [1] 

[jira] [Updated] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default

[ https://issues.apache.org/jira/browse/FLINK-5728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5728: --- Priority: Major (was: Blocker) > FlinkKafkaProducer should flush on checkpoint by

[jira] [Closed] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing

[ https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-5704. -- Resolution: Won't Fix > Deprecate FlinkKafkaConsumer constructors in favor of

[jira] [Updated] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing

[ https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5704: --- Fix Version/s: (was: 1.5.0) > Deprecate FlinkKafkaConsumer constructors in favor

[jira] [Updated] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing

[ https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5704: --- Priority: Major (was: Blocker) > Deprecate FlinkKafkaConsumer constructors in favor

[jira] [Reopened] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing

[ https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-5704: > Deprecate FlinkKafkaConsumer constructors in favor of improvements to > decoupling

[jira] [Closed] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing

[ https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-5704. -- Resolution: Won't Fix > Deprecate FlinkKafkaConsumer constructors in favor of

[jira] [Commented] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing

[ https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361895#comment-16361895 ] Tzu-Li (Gordon) Tai commented on FLINK-5704: There was some discussion on the mailing list [1]

[jira] [Reopened] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal reopened FLINK-7756: - [~aljoscha] [~kkl0u] I have checked with 1.4.1-rc1 and 1.5.0 snapshot still it's running

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-7756: Attachment: jobmanager.log taskmanager.log > RocksDB state backend

[jira] [Updated] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal updated FLINK-6321: Attachment: jobmanager.log taskmanager.log > RocksDB state backend

[jira] [Reopened] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shashank Agarwal reopened FLINK-6321: - [~aljoscha] [~kkl0u] I have checked with 1.4.1-rc1 and 1.5.0 snapshot still it's running

[jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.0

[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361750#comment-16361750 ] mingleizhang commented on FLINK-8335: - OKay. Thanks ~ :) > Upgrade hbase connector dependency to

[jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.0

[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361745#comment-16361745 ] Ted Yu commented on FLINK-8335: --- 1.4.1 has been released. > Upgrade hbase connector dependency to 1.4.0 >

[jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.0

[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361742#comment-16361742 ] mingleizhang commented on FLINK-8335: - Thanks [~yuzhih...@gmail.com] I will take a look on this when

[jira] [Commented] (FLINK-8423) OperatorChain#pushToOperator catch block may fail with NPE

[ https://issues.apache.org/jira/browse/FLINK-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361733#comment-16361733 ] ASF GitHub Bot commented on FLINK-8423: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #5447: [FLINK-8423] OperatorChain#pushToOperator catch bl...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5447#discussion_r167746607 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java --- @@ -591,16 +591,28 @@ public void

[jira] [Commented] (FLINK-7525) Add config option to disable Cancel functionality on UI

[ https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361702#comment-16361702 ] Ted Yu commented on FLINK-7525: --- I will watch subtasks of FLINK-4319 > Add config option to disable Cancel

[jira] [Updated] (FLINK-8335) Upgrade hbase connector dependency to 1.4.0

[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8335: -- Description: hbase 1.4.1 has been released. 1.4.0 shows speed improvement over previous 1.x releases.

[jira] [Updated] (FLINK-8042) Retry individual failover-strategy for some time first before reverting to full job restart

[ https://issues.apache.org/jira/browse/FLINK-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-8042: -- Description: Let's say we lost a taskmanager node. When Flink tries to attempt fine grained

[jira] [Commented] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization

[ https://issues.apache.org/jira/browse/FLINK-8533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361295#comment-16361295 ] ASF GitHub Bot commented on FLINK-8533: --- Github user EronWright commented on the issue:

[GitHub] flink issue #5427: [FLINK-8533] [checkpointing] Support MasterTriggerRestore...

Github user EronWright commented on the issue: https://github.com/apache/flink/pull/5427 @StephanEwen thanks for taking a look, I agree with trying to avoid a new lifecycle method. The `initializeState` method on the hook interface gives the hook an unconditional

[jira] [Comment Edited] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361174#comment-16361174 ] Chesnay Schepler edited comment on FLINK-8475 at 2/12/18 5:53 PM: --

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361174#comment-16361174 ] Chesnay Schepler commented on FLINK-8475: - partially addressed in:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361173#comment-16361173 ] ASF GitHub Bot commented on FLINK-8475: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361168#comment-16361168 ] ASF GitHub Bot commented on FLINK-8475: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361166#comment-16361166 ] ASF GitHub Bot commented on FLINK-8475: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361169#comment-16361169 ] ASF GitHub Bot commented on FLINK-8475: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361171#comment-16361171 ] ASF GitHub Bot commented on FLINK-8475: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361170#comment-16361170 ] ASF GitHub Bot commented on FLINK-8475: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361172#comment-16361172 ] ASF GitHub Bot commented on FLINK-8475: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361167#comment-16361167 ] ASF GitHub Bot commented on FLINK-8475: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361164#comment-16361164 ] ASF GitHub Bot commented on FLINK-8475: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361165#comment-16361165 ] ASF GitHub Bot commented on FLINK-8475: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5461: [FLINK-8475][config][docs] Integrate Mesos options

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5461 ---

[GitHub] flink pull request #5389: [FLINK-8475][config][docs] Integrate REST options

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5389 ---

[GitHub] flink pull request #5391: [FLINK-8475][config][docs] Integrate BlobServer op...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5391 ---

[GitHub] flink pull request #5386: [FLINK-8475][config][docs] Integrate netty options

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5386 ---

[GitHub] flink pull request #5387: [FLINK-8475][config][docs] Integrate optimizer opt...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5387 ---

[GitHub] flink pull request #5460: [FLINK-8475][config][docs] Integrate Algorithm opt...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5460 ---

[GitHub] flink pull request #5385: [FLINK-8475][config][docs] Integrate SSL options

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5385 ---

[GitHub] flink pull request #5464: [FLINK-8475][config][docs] Integrate Checkpointing...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5464 ---

[GitHub] flink pull request #5390: [FLINK-8475][config][docs] Integrate SlotManager o...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5390 ---

[GitHub] flink pull request #5392: [FLINK-8475][config][docs] Integrate JM options

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5392 ---

[jira] [Commented] (FLINK-8423) OperatorChain#pushToOperator catch block may fail with NPE

[ https://issues.apache.org/jira/browse/FLINK-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361156#comment-16361156 ] ASF GitHub Bot commented on FLINK-8423: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5447: [FLINK-8423] OperatorChain#pushToOperator catch bl...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5447#discussion_r167633643 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java --- @@ -591,16 +591,28 @@ public void

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361126#comment-16361126 ] ASF GitHub Bot commented on FLINK-8475: --- GitHub user zentol opened a pull request:

[jira] [Commented] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization

[ https://issues.apache.org/jira/browse/FLINK-8533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361128#comment-16361128 ] ASF GitHub Bot commented on FLINK-8533: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5427: [FLINK-8533] [checkpointing] Support MasterTriggerRestore...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5427 Given the already non-trivial complexity of the `CheckpointCoordinator`, I am wondering if there is a way to do this without adding the `resetForNewExecution()` method. Adding another

[GitHub] flink pull request #5469: [FLINK-8475][config][docs] Integrate Core options

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5469 [FLINK-8475][config][docs] Integrate Core options ## What is the purpose of the change This PR integrates the core `ConfigOptions` into the configuration docs generator. Do note

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361112#comment-16361112 ] ASF GitHub Bot commented on FLINK-8475: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5468: [FLINK-8475][config][docs] Integrate Environment o...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5468 [FLINK-8475][config][docs] Integrate Environment options ## What is the purpose of the change This PR integrates the environment `ConfigOptions` into the configuration docs generator.

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361109#comment-16361109 ] ASF GitHub Bot commented on FLINK-8475: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5467: [FLINK-8475][config][docs] Integrate HA options

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5467 [FLINK-8475][config][docs] Integrate HA options ## What is the purpose of the change This PR integrates the HA `ConfigOptions` into the configuration docs generator. ## Brief

[jira] [Updated] (FLINK-8641) Move BootstrapTools#getTaskManagerShellCommand to flink-yarn

[ https://issues.apache.org/jira/browse/FLINK-8641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8641: Description: I would like to move {{getTaskManagerShellCommand()}} and

[jira] [Created] (FLINK-8641) Move BootstrapTools#getTaskManagerShellCommand to flink-yarn

Chesnay Schepler created FLINK-8641: --- Summary: Move BootstrapTools#getTaskManagerShellCommand to flink-yarn Key: FLINK-8641 URL: https://issues.apache.org/jira/browse/FLINK-8641 Project: Flink

[GitHub] flink issue #5385: [FLINK-8475][config][docs] Integrate SSL options

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5385 merging, ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361060#comment-16361060 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

[ https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361048#comment-16361048 ] ASF GitHub Bot commented on FLINK-6469: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5448: [FLINK-6469] Configure Memory Sizes with units

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5448 Thanks, I think this is a really nice change! Given that we are approaching feature freeze for 1.5 and already have a very big backlog, I would try and get to this for the 1.6 release.

[GitHub] flink pull request #5463: [FLINK-8475][config][docs] Integrate YARN options

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5463#discussion_r167615886 --- Diff: docs/ops/config.md --- @@ -408,38 +408,7 @@ of the JobManager, because the same ActorSystem is used. Its not possible to use ### YARN

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361046#comment-16361046 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361037#comment-16361037 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5463: [FLINK-8475][config][docs] Integrate YARN options

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5463#discussion_r167613681 --- Diff: docs/ops/config.md --- @@ -408,38 +408,7 @@ of the JobManager, because the same ActorSystem is used. Its not possible to use ### YARN

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361035#comment-16361035 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5463: [FLINK-8475][config][docs] Integrate YARN options

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5463#discussion_r167613260 --- Diff: docs/ops/config.md --- @@ -408,38 +408,7 @@ of the JobManager, because the same ActorSystem is used. Its not possible to use ### YARN

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361033#comment-16361033 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361032#comment-16361032 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5463: [FLINK-8475][config][docs] Integrate YARN options

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5463#discussion_r167612255 --- Diff: docs/ops/config.md --- @@ -408,38 +408,7 @@ of the JobManager, because the same ActorSystem is used. Its not possible to use ### YARN

[GitHub] flink pull request #5463: [FLINK-8475][config][docs] Integrate YARN options

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5463#discussion_r167612224 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java --- @@ -79,14 +87,18 @@ */ public static

[jira] [Commented] (FLINK-8608) Add MiniDispatcher for job mode

[ https://issues.apache.org/jira/browse/FLINK-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361030#comment-16361030 ] ASF GitHub Bot commented on FLINK-8608: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5431: [FLINK-8608] [flip6] Implement MiniDispatcher for ...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5431#discussion_r167610671 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java --- @@ -262,32 +430,151 @@ protected void shutDown(boolean

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361028#comment-16361028 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #5463: [FLINK-8475][config][docs] Integrate YARN options

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5463#discussion_r167611073 --- Diff: docs/ops/config.md --- @@ -408,38 +408,7 @@ of the JobManager, because the same ActorSystem is used. Its not possible to use ### YARN

[GitHub] flink issue #5464: [FLINK-8475][config][docs] Integrate Checkpointing option...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5464 merging. ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361025#comment-16361025 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361022#comment-16361022 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8608) Add MiniDispatcher for job mode

[ https://issues.apache.org/jira/browse/FLINK-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361020#comment-16361020 ] ASF GitHub Bot commented on FLINK-8608: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8608) Add MiniDispatcher for job mode

[ https://issues.apache.org/jira/browse/FLINK-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361019#comment-16361019 ] ASF GitHub Bot commented on FLINK-8608: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8608) Add MiniDispatcher for job mode

[ https://issues.apache.org/jira/browse/FLINK-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361021#comment-16361021 ] ASF GitHub Bot commented on FLINK-8608: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8608) Add MiniDispatcher for job mode

[ https://issues.apache.org/jira/browse/FLINK-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361018#comment-16361018 ] ASF GitHub Bot commented on FLINK-8608: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5462: [FLINK-8475][config][docs] Integrate HA-ZK options

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5462#discussion_r167610029 --- Diff: docs/ops/config.md --- @@ -502,27 +502,7 @@ Previously this key was named `recovery.mode` and the default value was `standal

[GitHub] flink pull request #5431: [FLINK-8608] [flip6] Implement MiniDispatcher for ...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5431#discussion_r167608001 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java --- @@ -300,4 +587,12 @@ protected static ClusterConfiguration

[GitHub] flink pull request #5431: [FLINK-8608] [flip6] Implement MiniDispatcher for ...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5431#discussion_r167601541 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/MiniDispatcherTest.java --- @@ -0,0 +1,208 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #5431: [FLINK-8608] [flip6] Implement MiniDispatcher for ...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5431#discussion_r167606814 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java --- @@ -63,6 +89,10 @@ */ public abstract class

[GitHub] flink pull request #5431: [FLINK-8608] [flip6] Implement MiniDispatcher for ...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5431#discussion_r167593183 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java --- @@ -671,13 +674,68 @@ public void jobFinishedByOther() {

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361009#comment-16361009 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361006#comment-16361006 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361008#comment-16361008 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361007#comment-16361007 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #5462: [FLINK-8475][config][docs] Integrate HA-ZK options

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5462#discussion_r167609071 --- Diff: docs/ops/config.md --- @@ -502,27 +502,7 @@ Previously this key was named `recovery.mode` and the default value was `standal

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361004#comment-16361004 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361005#comment-16361005 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #5463: [FLINK-8475][config][docs] Integrate YARN options

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5463#discussion_r167607077 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java --- @@ -79,14 +87,18 @@ */ public static

[GitHub] flink pull request #5463: [FLINK-8475][config][docs] Integrate YARN options

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5463#discussion_r167607428 --- Diff: docs/ops/config.md --- @@ -408,38 +408,7 @@ of the JobManager, because the same ActorSystem is used. Its not possible to use ### YARN

  1   2   3   >