Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5774
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5774#discussion_r177739972
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -507,19 +539,21 @@ private TestingDispatcher(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5774#discussion_r177726769
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -507,19 +539,21 @@ private TestingDispatcher(
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5774#discussion_r177734109
--- Diff: flink-runtime/src/test/resources/log4j-test.properties ---
@@ -16,7 +16,7 @@
# limitations under the License.
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5774#discussion_r177725828
--- Diff: flink-runtime/src/test/resources/log4j-test.properties ---
@@ -16,7 +16,7 @@
# limitations under the License.
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5774
[FLINK-9097] Fail fatally if job submission fails when recovering jobs
## What is the purpose of the change
In order to not drop jobs, we have to fail fatally if a job submission