Skip to content

Commit e5b3274

Browse files
authored
[hotfix] Remove unused DurableExecutionManager.maybePruneState helper (#682)
1 parent cfb7127 commit e5b3274

2 files changed

Lines changed: 0 additions & 7 deletions

File tree

runtime/src/main/java/org/apache/flink/agents/runtime/operator/DurableExecutionManager.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -319,12 +319,6 @@ public void persist(
319319
}
320320
}
321321

322-
void maybePruneState(Object key, long sequenceNum) throws Exception {
323-
if (actionStateStore != null) {
324-
actionStateStore.pruneState(key, sequenceNum);
325-
}
326-
}
327-
328322
/**
329323
* Prunes durable state for all per-key sequence numbers that were captured at the time of the
330324
* given checkpoint.

runtime/src/test/java/org/apache/flink/agents/runtime/operator/DurableExecutionManagerTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,6 @@ void noStoreModeMakesAllMaybeOperationsNoOp() throws Exception {
6565
// Every maybe* method must be a silent no-op.
6666
assertThat(dem.maybeGetActionState("k", 0L, action, event)).isNull();
6767
dem.maybeInitActionState("k", 0L, action, event);
68-
dem.maybePruneState("k", 0L);
6968
dem.notifyCheckpointComplete(1L);
7069
dem.snapshotRecoveryMarker();
7170
dem.close();

0 commit comments

Comments
 (0)