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

feat: optimize TaskTracker log #858

Browse Source
This commit is contained in:
tjq 2024-03-16 13:15:41 +08:00
parent b822a685f4
commit a9d8a680dc
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
powerjob-worker/src/main/java/tech/powerjob/worker/core/tracker/task/heavy/HeavyTaskTracker.java
View File

@ -201,9 +201,9 @@ public abstract class HeavyTaskTracker extends TaskTracker {
instanceId, subInstanceId, taskBriefInfo.getLastReportTime(), reportTime, taskId, newStatus); instanceId, subInstanceId, taskBriefInfo.getLastReportTime(), reportTime, taskId, newStatus);
return; return;
} }
// 检查状态转移是否合法，fix issue 404 // 检查状态转移是否合法，fix issue 404（20240306：无排队情况下，receive 和 running 几乎会在同一时间触发，导致这两个请求先后顺序几乎无法保证，大概率有此行输出，因此日志级别降级到 INFO）
if (nTaskStatus.getValue() < taskBriefInfo.getStatus().getValue()) { if (nTaskStatus.getValue() < taskBriefInfo.getStatus().getValue()) {
log.warn("[TaskTracker-{}-{}] receive invalid task status report(taskId={},currentStatus={},newStatus={}), TaskTracker will drop this report.", log.info("[TaskTracker-{}-{}] receive invalid task status report(taskId={},currentStatus={},newStatus={}), TaskTracker will drop this report.",
instanceId, subInstanceId, taskId, taskBriefInfo.getStatus().getValue(), newStatus); instanceId, subInstanceId, taskId, taskBriefInfo.getStatus().getValue(), newStatus);
return; return;
} }