Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5223
---
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161368455
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.java
---
@@ -0,0 +1,337 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161243207
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java
---
@@ -137,4 +138,21 @@
JobID
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161243072
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.java
---
@@ -0,0 +1,337 @@
+/*
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161242967
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.java
---
@@ -0,0 +1,337 @@
+/*
+
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161242333
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlersTest.java
---
@@ -0,0 +1,277 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161242312
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/job/savepoints/SavepointInfoTest.java
---
@@ -0,0 +1,52 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161242316
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlersTest.java
---
@@ -0,0 +1,277 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161242267
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
---
@@ -185,37 +205,19 @@ private void submitJob(JobGraph
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161242245
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java
---
@@ -294,44 +306,108 @@ public void
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161242236
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java
---
@@ -294,44 +306,108 @@ public void
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161238338
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.java
---
@@ -0,0 +1,337 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161236268
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.java
---
@@ -0,0 +1,337 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161235482
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java
---
@@ -137,4 +138,21 @@
JobID jobId,
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161234791
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
---
@@ -185,37 +205,19 @@ private void submitJob(JobGraph
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161230366
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/job/savepoints/SavepointInfoTest.java
---
@@ -0,0 +1,52 @@
+/*
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161228957
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlersTest.java
---
@@ -0,0 +1,277 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161229580
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlersTest.java
---
@@ -0,0 +1,277 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161230839
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java
---
@@ -137,4 +138,21 @@
JobID
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161224559
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.java
---
@@ -0,0 +1,337 @@
+/*
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161218205
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java
---
@@ -185,37 +205,19 @@ private void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161220129
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java
---
@@ -294,44 +306,108 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161224329
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.java
---
@@ -0,0 +1,337 @@
+/*
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161220157
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java
---
@@ -294,44 +306,108 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161228758
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcUtils.java ---
@@ -27,11 +27,16 @@
import
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161163547
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcUtils.java ---
@@ -27,11 +27,16 @@
import java.util.concurrent.TimeoutException;
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161163558
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlersTest.java
---
@@ -0,0 +1,276 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r161163563
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/rest/retry/ExponentialWaitStrategyTest.java
---
@@ -0,0 +1,65 @@
+/*
+ * Licensed
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r160431822
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlersTest.java
---
@@ -0,0 +1,276 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5223#discussion_r159247245
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcUtils.java ---
@@ -27,11 +27,16 @@
import java.util.concurrent.TimeoutException;
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5223
[FLINK-8317][flip6] Implement Triggering of Savepoints
## What is the purpose of the change
*Implement triggering of savepoints through HTTP and through command line
in FLIP-6 mode. This PR is
31 matches
Mail list logo
