From d72070255f6de37037b05f48417251b91eac7698 Mon Sep 17 00:00:00 2001 From: vainhope <845869847@qq.com> Date: Thu, 8 Dec 2022 10:49:02 +0800 Subject: [PATCH] [issue_934][taier-schedule] fix hour schedule task fill data only one schedule job fix #934 --- .../taier/scheduler/server/builder/FillDataJobBuilder.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/taier-scheduler/src/main/java/com/dtstack/taier/scheduler/server/builder/FillDataJobBuilder.java b/taier-scheduler/src/main/java/com/dtstack/taier/scheduler/server/builder/FillDataJobBuilder.java index 014cd5fd5f..12fd191e32 100644 --- a/taier-scheduler/src/main/java/com/dtstack/taier/scheduler/server/builder/FillDataJobBuilder.java +++ b/taier-scheduler/src/main/java/com/dtstack/taier/scheduler/server/builder/FillDataJobBuilder.java @@ -168,7 +168,9 @@ private void addMap(Set run, List 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())); + } } /**