perf: file-gateway调度逻辑优化 TencentBlueKing#2977

限定重调度区间为最近半小时
jsonwan · May 14, 2024 · bc2518f · bc2518f
1 parent b0c0292
commit bc2518f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...ay/src/main/java/com/tencent/bk/job/file_gateway/task/dispatch/ReDispatchTimeoutTask.java b/...ay/src/main/java/com/tencent/bk/job/file_gateway/task/dispatch/ReDispatchTimeoutTask.java
@@ -112,14 +112,18 @@ private void reDispatchFileSourceTasks() {
             0,
             -1
         );
+        watch.stop();
+        if (timeoutFileSourceTaskIdList.isEmpty()) {
+            log.info("no fileSourceTask need to be reDispatch");
+            return;
+        }
         log.info(
             "find {} fileSourceTask between [{},{}] to reDispatch: {}",
             timeoutFileSourceTaskIdList.size(),
             TimeUtil.formatTime(intervalStart),
             TimeUtil.formatTime(intervalEnd),
             timeoutFileSourceTaskIdList
         );
-        watch.stop();
         watch.start("reDispatch Tasks");
         // 进行超时重调度
         for (String fileSourceTaskId : timeoutFileSourceTaskIdList) {