Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5764
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5764#discussion_r177320500
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java
---
@@ -534,6 +534,18 @@ public void start() throws
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5764#discussion_r177320486
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java
---
@@ -536,6 +546,103 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5764#discussion_r177319256
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -344,6 +363,42 @@ public void testJobRecovery()
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5764#discussion_r177319125
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/savepoints/SavepointDisposalRequest.java
---
@@ -0,0 +1,47 @@
+/*
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5764#discussion_r177080293
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java
---
@@ -536,6 +546,103 @@ public void
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5764#discussion_r177082615
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/savepoints/SavepointDisposalRequest.java
---
@@ -0,0 +1,47 @@
+/*
+
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5764#discussion_r177083854
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -344,6 +363,42 @@ public void testJobRecovery() throws
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5764#discussion_r177080326
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java
---
@@ -534,6 +534,18 @@ public void start() throws Exception {
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5764
[FLINK-8940] [flip6] Add support for dispose savepoint
## What is the purpose of the change
Adds an AsynchronousOperationHandler for disposing savepoints. The handler
is registered
10 matches
Mail list logo
