Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5767
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5767#discussion_r177728773
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedLeaderService.java
---
@@ -440,28 +439,33 @@ pub
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5767#discussion_r177728701
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -645,6 +637,56 @@ private void
registerOrphanedJobMan
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5767#discussion_r177684059
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -645,6 +637,56 @@ private void
registerOrphanedJobManagerTermi
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5767#discussion_r177696032
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedLeaderService.java
---
@@ -440,28 +439,33 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5767#discussion_r177318939
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/MiniClusterClient.java
---
@@ -67,7 +61,7 @@
private final ScheduledExecu
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5767#discussion_r177163114
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/MiniClusterClient.java
---
@@ -67,7 +61,7 @@
private final ScheduledExecutorSer
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5767
[FLINK-8887] Wait for JobMaster leader election in Dispatcher
## What is the purpose of the change
Before sending requests from the Dispatcher to the JobMasters, the
Dispatcher must
