From 16a5f8efb64792b9cbb1c7c295c5a2baa9975788 Mon Sep 17 00:00:00 2001
From: tjq <tengjiqi@gmail.com>
Date: Wed, 17 Feb 2021 10:58:53 +0800
Subject: [PATCH] fix: TaskTracker should write address info into TaskDO when
 execute broadcast

---
 .../kfcfans/powerjob/worker/core/tracker/task/TaskTracker.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/TaskTracker.java b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/TaskTracker.java
index 4efc5430..7eafa6e3 100644
--- a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/TaskTracker.java
+++ b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/TaskTracker.java
@@ -312,6 +312,8 @@ public abstract class TaskTracker {
                 subTask.setSubInstanceId(subInstanceId);
                 subTask.setTaskName(TaskConstant.BROADCAST_TASK_NAME);
                 subTask.setTaskId(preTaskId + "." + i);
+                // 广播任务直接写入派发地址
+                subTask.setAddress(allWorkerAddress.get(i));
                 subTaskList.add(subTask);
             }
             submitTask(subTaskList);