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 worker log

Browse Source
This commit is contained in:
tjq 2022-09-17 23:47:10 +08:00
parent e501cb9dfa
commit dc90f272c7
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/background/ServerDiscoveryService.java
View File

@ -87,7 +87,7 @@ public class ServerDiscoveryService {
} }
if (StringUtils.isEmpty(result)) { if (StringUtils.isEmpty(result)) {
log.warn("[PowerDiscovery] can't find any available server, this worker has been quarantined."); log.warn("[PowerDiscovery] can't find any available server, this worker[appId={}] has been quarantined.", appId);
// 在 Server 高可用的前提下，连续失败多次，说明该节点与外界失联，Server已经将秒级任务转移到其他Worker，需要杀死本地的任务 // 在 Server 高可用的前提下，连续失败多次，说明该节点与外界失联，Server已经将秒级任务转移到其他Worker，需要杀死本地的任务
if (FAILED_COUNT++ > MAX_FAILED_COUNT) { if (FAILED_COUNT++ > MAX_FAILED_COUNT) {
@ -108,7 +108,7 @@ public class ServerDiscoveryService {
} else { } else {
// 重置失败次数 // 重置失败次数
FAILED_COUNT = 0; FAILED_COUNT = 0;
log.debug("[PowerDiscovery] current server is {}.", result); log.debug("[PowerDiscovery] appId={}, current server is {}.", appId, result);
return result; return result;
} }
} }