[hotfix][runtime] Remove useless class ZooKeeperCompletedCheckpointSt…

…oreITCase This closes apache#12083
static-max · May 14, 2020 · f05faee · f05faee
1 parent e0438f9
commit f05faee
Showing 1 changed file with 0 additions and 9 deletions.
diff --git a/...est/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreITCase.java b/...est/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreITCase.java
@@ -23,7 +23,6 @@
 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 void testConcurrentCheckpointOperations() throws Exception {
  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;