[Hotfix][Zeta] Fix task state memory leak (#5139)

apache · Jul 24, 2023 · a6c7ca1 · a6c7ca1
1 parent 6f30b29
commit a6c7ca1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...el-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java b/...el-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java
@@ -341,7 +341,7 @@ public void ack(Barrier barrier) {
                                 new TaskAcknowledgeOperation(
                                         this.taskLocation,
                                         (CheckpointBarrier) barrier,
-                                        checkpointStates.get(barrier.getId())))
+                                        checkpointStates.remove(barrier.getId())))
                         .join();
             }
         }