Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5648#discussion_r172837682
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -404,16 +404,25 @@ public void start() throws Exception {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5648#discussion_r172835665
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -404,7 +406,29 @@ public void start() throws Exception {
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/5648#discussion_r172782747
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -404,16 +404,25 @@ public void start() throws Exception {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5648#discussion_r172775779
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -404,16 +404,25 @@ public void start() throws Exception {
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/5648
[FLINK-8887][flip-6] ClusterClient.getJobStatus can throw
FencingTokenException
## What is the purpose of the change
*This pull request fixed ClusterClient.getJobStatus throw
