[Fix][Zeta] Fix SinkFlowLifeCycle without init lastCommitInfo (#5152)

apache · Jul 27, 2023 · 3e9b9f5 · 3e9b9f5
1 parent 1f94676
commit 3e9b9f5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/SinkFlowLifeCycle.java b/...-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/SinkFlowLifeCycle.java
@@ -109,6 +109,7 @@ public SinkFlowLifeCycle(
     public void init() throws Exception {
         this.writerStateSerializer = sinkAction.getSink().getWriterStateSerializer();
         this.committer = sinkAction.getSink().createCommitter();
+        this.lastCommitInfo = Optional.empty();
     }
 
     @Override