Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5560
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5560#discussion_r170314390
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -534,42 +536,94 @@ public void postStop() throws
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5560#discussion_r170314325
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointTriggerException.java
---
@@ -0,0 +1,42 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5560#discussion_r170314219
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskAsyncCallTest.java
---
@@ -289,7 +290,7 @@ public void invoke() throws
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5560#discussion_r170313695
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -1156,6 +1213,26 @@ private void
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5560#discussion_r170279814
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -1156,6 +1213,26 @@ private void disposeSavepoint(String
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5560#discussion_r170296322
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointTriggerException.java
---
@@ -0,0 +1,42 @@
+/*
+ * Licensed to the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5560#discussion_r170296168
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointTriggerException.java
---
@@ -0,0 +1,42 @@
+/*
+ * Licensed to the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5560#discussion_r170300254
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -534,42 +536,94 @@ public void postStop() throws Exception {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5560#discussion_r170281192
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskAsyncCallTest.java
---
@@ -289,7 +290,7 @@ public void invoke() throws Exception
10 matches
Mail list logo