Github user yuqi1129 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5846#discussion_r191211627
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java
---
@@ -896,6 +898,10 @@ public static JobGraph
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/5846#discussion_r191150742
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java
---
@@ -896,6 +898,10 @@ public static JobGraph
Github user yuqi1129 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5846#discussion_r191143764
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -255,6 +264,35 @@ public void start() throws Exception {
Github user yuqi1129 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5846#discussion_r191143882
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -255,6 +264,35 @@ public void start() throws Exception {
Github user yuqi1129 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5846#discussion_r191143746
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java
---
@@ -896,6 +898,10 @@ public static JobGraph
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/5846#discussion_r191133405
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -255,6 +264,35 @@ public void start() throws Exception {
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/5846#discussion_r191140799
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -250,6 +259,35 @@ public void start() throws Exception {
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/5846#discussion_r191133308
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java
---
@@ -896,6 +898,10 @@ public static JobGraph
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/5846#discussion_r191133623
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -255,6 +264,35 @@ public void start() throws Exception {
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/5846#discussion_r191133512
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -255,6 +264,35 @@ public void start() throws Exception {
GitHub user yuqi1129 opened a pull request:
https://github.com/apache/flink/pull/5846
[FLINK-9143] [client] Restart strategy defined in flink-conf.yaml is ignored
## What is the purpose of the change
This change is to fix the bug that if restart strategy was not
11 matches
Mail list logo