diff --git a/dolphinscheduler-tools/src/main/java/org/apache/dolphinscheduler/tools/datasource/dao/JsonSplitDao.java b/dolphinscheduler-tools/src/main/java/org/apache/dolphinscheduler/tools/datasource/dao/JsonSplitDao.java
index 2a411df994..c7893764ea 100644
--- a/dolphinscheduler-tools/src/main/java/org/apache/dolphinscheduler/tools/datasource/dao/JsonSplitDao.java
+++ b/dolphinscheduler-tools/src/main/java/org/apache/dolphinscheduler/tools/datasource/dao/JsonSplitDao.java
@@ -17,6 +17,7 @@
 
 package org.apache.dolphinscheduler.tools.datasource.dao;
 
+import org.apache.dolphinscheduler.common.enums.TimeoutFlag;
 import org.apache.dolphinscheduler.dao.entity.ProcessDefinitionLog;
 import org.apache.dolphinscheduler.dao.entity.ProcessTaskRelationLog;
 import org.apache.dolphinscheduler.dao.entity.TaskDefinitionLog;
@@ -191,7 +192,7 @@ public class JsonSplitDao {
                 insert.setLong(12, taskDefinitionLog.getEnvironmentCode());
                 insert.setInt(13, taskDefinitionLog.getFailRetryTimes());
                 insert.setInt(14, taskDefinitionLog.getFailRetryInterval());
-                insert.setInt(15, taskDefinitionLog.getTimeoutFlag().getCode());
+                insert.setInt(15, taskDefinitionLog.getTimeoutFlag() == null ? TimeoutFlag.CLOSE.getCode() : taskDefinitionLog.getTimeoutFlag().getCode());
                 insert.setInt(16, taskDefinitionLog.getTimeoutNotifyStrategy() == null ? 0
                         : taskDefinitionLog.getTimeoutNotifyStrategy().getCode());
                 insert.setInt(17, taskDefinitionLog.getTimeout());