diff --git a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/common/constants/TaskStatus.java b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/common/constants/TaskStatus.java
index 1ec13f93..05ba19e3 100644
--- a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/common/constants/TaskStatus.java
+++ b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/common/constants/TaskStatus.java
@@ -1,10 +1,10 @@
 package com.github.kfcfans.powerjob.worker.common.constants;
 
-import com.google.common.collect.Lists;
+import com.google.common.collect.Sets;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
-import java.util.List;
+import java.util.Set;
 
 /**
  * 任务状态，task_info 表中 status 字段的枚举值
@@ -23,10 +23,10 @@ public enum TaskStatus {
     WORKER_PROCESS_FAILED(5, "worker执行失败"),
     WORKER_PROCESS_SUCCESS(6, "worker执行成功");
 
-    public static final List<Integer> finishedStatus = Lists.newArrayList(WORKER_PROCESS_FAILED.value, WORKER_PROCESS_SUCCESS.value);
+    public static final Set<Integer> finishedStatus = Sets.newHashSet(WORKER_PROCESS_FAILED.value, WORKER_PROCESS_SUCCESS.value);
 
-    private int value;
-    private String des;
+    private final int value;
+    private final String des;
 
     public static TaskStatus of(int v) {
         for (TaskStatus taskStatus : values()) {
diff --git a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/executor/ProcessorRunnable.java b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/executor/ProcessorRunnable.java
index 4000dd47..8a3798cd 100644
--- a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/executor/ProcessorRunnable.java
+++ b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/executor/ProcessorRunnable.java
@@ -177,9 +177,9 @@ public class ProcessorRunnable implements Runnable {
             if (!success) {
                 // 插入重试队列，等待重试
                 statusReportRetryQueue.add(req);
-                log.warn("[ProcessorRunnable-{}] report task(id={},status={},result={}) failed.", task.getInstanceId(), task.getTaskId(), status, result);
+                log.warn("[ProcessorRunnable-{}] report task(id={},status={},result={}) failed, will retry later", task.getInstanceId(), task.getTaskId(), status, result);
             }
-        }else {
+        } else {
             taskTrackerActor.tell(req, null);
         }
     }
diff --git a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTracker.java b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTracker.java
index 15876cb6..f4909ae3 100644
--- a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTracker.java
+++ b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTracker.java
@@ -268,6 +268,7 @@ public class ProcessorTracker {
                     req.setReportTime(System.currentTimeMillis());
                     if (!AkkaUtils.reliableTransmit(taskTrackerActorRef, req)) {
                         statusReportRetryQueue.add(req);
+                        log.warn("[ProcessorRunnable-{}] retry report finished task status failed: {}", instanceId, req);
                         return;
                     }
                 }
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 f8856edc..463c7aee 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
@@ -301,7 +301,7 @@ public abstract class TaskTracker {
             return;
         }
 
-        log.info("[TaskTracker-{}] finished broadcast's preProcess.", instanceId);
+        log.info("[TaskTracker-{}-{}] finished broadcast's preProcess, preExecuteSuccess:{},preTaskId:{},result:{}", instanceId, subInstanceId, preExecuteSuccess, preTaskId, result);
 
         // 生成集群子任务
         if (preExecuteSuccess) {
@@ -316,7 +316,7 @@ public abstract class TaskTracker {
             }
             submitTask(subTaskList);
         }else {
-            log.debug("[TaskTracker-{}] BroadcastTask failed because of preProcess failed, preProcess result={}.", instanceId, result);
+            log.warn("[TaskTracker-{}-{}] BroadcastTask failed because of preProcess failed, preProcess result={}.", instanceId, subInstanceId, result);
         }
     }