(flink-agents) branch main updated: [hotfix] Remove unused DurableExecutionManager.maybePruneState helper (#682)

[wenjin]

This is an automated email from the ASF dual-hosted git repository.

wenjin272 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git


The following commit(s) were added to refs/heads/main by this push:
     new e5b3274b [hotfix] Remove unused 
DurableExecutionManager.maybePruneState helper (#682)
e5b3274b is described below

commit e5b3274be3b4d4cf22772300cc997ceb41267dbf
Author: Weiqing Yang <wiy...@linkedin.com>
AuthorDate: Sat May 16 08:32:37 2026 -0700

    [hotfix] Remove unused DurableExecutionManager.maybePruneState helper (#682)
---
 .../flink/agents/runtime/operator/DurableExecutionManager.java      | 6 ------
 .../flink/agents/runtime/operator/DurableExecutionManagerTest.java  | 1 -
 2 files changed, 7 deletions(-)

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 295b36c9..3b24b3ab 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 @@ class DurableExecutionManager implements 
ActionStatePersister, AutoCloseable {
         }
     }
 
-    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 4d62dc16..88775255 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
@@ -65,7 +65,6 @@ class DurableExecutionManagerTest {
         // 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();