diff --git a/runtime/src/main/java/org/apache/flink/agents/runtime/operator/DurableExecutionManager.java b/runtime/src/main/java/org/apache/flink/agents/runtime/operator/DurableExecutionManager.java index 85c5df23a..d2b324e9a 100644 --- a/runtime/src/main/java/org/apache/flink/agents/runtime/operator/DurableExecutionManager.java +++ b/runtime/src/main/java/org/apache/flink/agents/runtime/operator/DurableExecutionManager.java @@ -319,12 +319,6 @@ public void persist( } } - void maybePruneState(Object key, long sequenceNum) throws Exception { - if (actionStateStore != null) { - actionStateStore.pruneState(key, sequenceNum); - } - } - /** * Prunes durable state for all per-key sequence numbers that were captured at the time of the * given checkpoint. diff --git a/runtime/src/test/java/org/apache/flink/agents/runtime/operator/DurableExecutionManagerTest.java b/runtime/src/test/java/org/apache/flink/agents/runtime/operator/DurableExecutionManagerTest.java index f5fc2a172..de8a653cf 100644 --- a/runtime/src/test/java/org/apache/flink/agents/runtime/operator/DurableExecutionManagerTest.java +++ b/runtime/src/test/java/org/apache/flink/agents/runtime/operator/DurableExecutionManagerTest.java @@ -64,7 +64,6 @@ void noStoreModeMakesAllMaybeOperationsNoOp() throws Exception { // Every maybe* method must be a silent no-op. assertThat(dem.maybeGetActionState("k", 0L, action, event)).isNull(); dem.maybeInitActionState("k", 0L, action, event); - dem.maybePruneState("k", 0L); dem.notifyCheckpointComplete(1L); dem.snapshotRecoveryMarker(); dem.close();