[issue_934][taier-schedule] fix hour schedule task fill data only one…

… schedule job. (#935)
DTStack · Dec 9, 2022 · 4f6a093 · 4f6a093
1 parent edf2d6b
commit 4f6a093
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...cheduler/src/main/java/com/dtstack/taier/scheduler/server/builder/FillDataJobBuilder.java b/...cheduler/src/main/java/com/dtstack/taier/scheduler/server/builder/FillDataJobBuilder.java
@@ -168,7 +168,9 @@ private void addMap(Set<Long> run, List<ScheduleJobDetails> saveList, Long taskI
         }
 
         saveList.add(jobBuilderBean);
-        saveList.addAll(jobBuilderBean.getFlowBean().stream().peek(flowBean -> flowBean.getScheduleJob().setFillType(FillJobTypeEnum.RUN_JOB.getType())).collect(Collectors.toList()));
+        if (CollectionUtils.isNotEmpty(jobBuilderBean.getFlowBean())) {
+            saveList.addAll(jobBuilderBean.getFlowBean().stream().peek(flowBean -> flowBean.getScheduleJob().setFillType(FillJobTypeEnum.RUN_JOB.getType())).collect(Collectors.toList()));
+        }
     }
 
     /**