third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: optimize ProcessorTracker log

Browse Source
This commit is contained in:
tjq 2021-01-03 14:27:00 +08:00
parent 6fc5c65825
commit b6173967bb
4 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/common/constants/TaskStatus.java
View File

@ -1,10 +1,10 @@
package com.github.kfcfans.powerjob.worker.common.constants; 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.AllArgsConstructor;
import lombok.Getter; import lombok.Getter;
import java.util.List; import java.util.Set;
/** /**
* 任务状态，task_info 表中 status 字段的枚举值 * 任务状态，task_info 表中 status 字段的枚举值
@ -23,10 +23,10 @@ public enum TaskStatus {
WORKER_PROCESS_FAILED(5, "worker执行失败"), WORKER_PROCESS_FAILED(5, "worker执行失败"),
WORKER_PROCESS_SUCCESS(6, "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 final int value;
private String des; private final String des;
public static TaskStatus of(int v) { public static TaskStatus of(int v) {
for (TaskStatus taskStatus : values()) { for (TaskStatus taskStatus : values()) {

4
powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/executor/ProcessorRunnable.java
View File

@ -177,9 +177,9 @@ public class ProcessorRunnable implements Runnable {
if (!success) { if (!success) {
// 插入重试队列，等待重试 // 插入重试队列，等待重试
statusReportRetryQueue.add(req); 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); taskTrackerActor.tell(req, null);
} }
} }

1
powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/processor/ProcessorTracker.java
View File

@ -268,6 +268,7 @@ public class ProcessorTracker {
req.setReportTime(System.currentTimeMillis()); req.setReportTime(System.currentTimeMillis());
if (!AkkaUtils.reliableTransmit(taskTrackerActorRef, req)) { if (!AkkaUtils.reliableTransmit(taskTrackerActorRef, req)) {
statusReportRetryQueue.add(req); statusReportRetryQueue.add(req);
log.warn("[ProcessorRunnable-{}] retry report finished task status failed: {}", instanceId, req);
return; return;
} }
} }

4
powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/core/tracker/task/TaskTracker.java
View File

@ -301,7 +301,7 @@ public abstract class TaskTracker {
return; 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) { if (preExecuteSuccess) {
@ -316,7 +316,7 @@ public abstract class TaskTracker {
} }
submitTask(subTaskList); submitTask(subTaskList);
}else { }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);
} }
} }