You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2020/05/14 13:31:17 UTC
[flink] 02/03: [hotfix][runtime] Remove useless class
ZooKeeperCompletedCheckpointStoreITCase
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit f05faeefde743212910c5cbbb3ad5e7bb88a5792
Author: felixzheng <fe...@gmail.com>
AuthorDate: Mon May 11 19:55:39 2020 +0800
[hotfix][runtime] Remove useless class ZooKeeperCompletedCheckpointStoreITCase
This closes #12083
---
.../checkpoint/ZooKeeperCompletedCheckpointStoreITCase.java | 9 ---------
1 file changed, 9 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreITCase.java
index 859f1b9..725d4df 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreITCase.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreITCase.java
@@ -23,7 +23,6 @@ import org.apache.flink.runtime.concurrent.Executors;
import org.apache.flink.runtime.state.RetrievableStateHandle;
import org.apache.flink.runtime.state.SharedStateRegistry;
import org.apache.flink.runtime.util.ZooKeeperUtils;
-import org.apache.flink.runtime.zookeeper.RetrievableStateStorageHelper;
import org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore;
import org.apache.flink.runtime.zookeeper.ZooKeeperTestEnvironment;
@@ -284,14 +283,6 @@ public class ZooKeeperCompletedCheckpointStoreITCase extends CompletedCheckpoint
recoveredTestCheckpoint.awaitDiscard();
}
-
- static class HeapStateStorageHelper implements RetrievableStateStorageHelper<CompletedCheckpoint> {
- @Override
- public RetrievableStateHandle<CompletedCheckpoint> store(CompletedCheckpoint state) throws Exception {
- return new HeapRetrievableStateHandle<>(state);
- }
- }
-
static class HeapRetrievableStateHandle<T extends Serializable> implements RetrievableStateHandle<T> {
private static final long serialVersionUID = -268548467968932L;