[improve][zeta] fix zeta bugs

apache · May 5, 2023 · 350e8ca · 350e8ca
1 parent 7eebdc4
commit 350e8ca
Showing 1 changed file with 4 additions and 0 deletions.
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
@@ -373,6 +373,10 @@ public void notifyAllAction(ConsumerWithException<InternalCheckpointListener> co
     @Override
     public void restoreState(List<ActionSubtaskState> actionStateList) throws Exception {
         log.debug("restoreState for SeaTunnelTask[{}]", actionStateList);
+        if (null == actionStateList) {
+            log.debug("restoreState is null, do nothing!");
+            return;
+        }
         Map<ActionStateKey, List<ActionSubtaskState>> stateMap =
                 actionStateList.stream()
                         .collect(