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 exception log in server elect #551

Browse Source
This commit is contained in:
tjq 2023-02-08 22:26:36 +08:00
parent a5e3e829b5
commit b89ac389fd
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/election/ServerElectionService.java
View File

@ -24,6 +24,7 @@ import java.util.Optional;
import java.util.Set; import java.util.Set;
import java.util.concurrent.ThreadLocalRandom; import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
/** /**
* Default server election policy, first-come, first-served, no load balancing capability * Default server election policy, first-come, first-served, no load balancing capability
@ -162,8 +163,10 @@ public class ServerElectionService {
log.warn("[ServerElection] server[{}] is active but don't have target protocol", serverAddress); log.warn("[ServerElection] server[{}] is active but don't have target protocol", serverAddress);
} }
} }
} catch (TimeoutException te) {
log.warn("[ServerElection] server[{}] was down due to ping timeout!", serverAddress);
} catch (Exception e) { } catch (Exception e) {
log.warn("[ServerElection] server[{}] was down.", serverAddress, e); log.warn("[ServerElection] server[{}] was down with unknown case!", serverAddress, e);
} }
downServerCache.add(serverAddress); downServerCache.add(serverAddress);
return null; return null;