From 36be03592ca0fb1b8c36e5cac806785985bca803 Mon Sep 17 00:00:00 2001 From: tjq Date: Sun, 26 Jul 2020 23:56:31 +0800 Subject: [PATCH] [fix] fix the problem of log uncorrect --- .../kfcfans/powerjob/worker/core/tracker/task/TaskTracker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 3b6a3537..a34401c4 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 @@ -176,7 +176,7 @@ public abstract class TaskTracker { // 过滤过期的请求(潜在的集群时间一致性需求,重试跨Worker时,时间不一致可能导致问题) if (lastReportTime > reportTime) { log.warn("[TaskTracker-{}] receive expired(last {} > current {}) task status report(taskId={},newStatus={}), TaskTracker will drop this report.", - lastReportTime, reportTime, instanceId, taskId, newStatus); + instanceId, lastReportTime, reportTime, taskId, newStatus); return; }