From b89ac389fd986b2bca65a48039e746959f63932a Mon Sep 17 00:00:00 2001 From: tjq Date: Wed, 8 Feb 2023 22:26:36 +0800 Subject: [PATCH] feat: optimize exception log in server elect #551 --- .../remote/server/election/ServerElectionService.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/election/ServerElectionService.java b/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/election/ServerElectionService.java index 5b0eb819..b2a86791 100644 --- a/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/election/ServerElectionService.java +++ b/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/server/election/ServerElectionService.java @@ -24,6 +24,7 @@ import java.util.Optional; import java.util.Set; import java.util.concurrent.ThreadLocalRandom; import java.util.concurrent.TimeUnit; +import java.util.concurrent.TimeoutException; /** * 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); } } - }catch (Exception e) { - log.warn("[ServerElection] server[{}] was down.", serverAddress, e); + } catch (TimeoutException te) { + log.warn("[ServerElection] server[{}] was down due to ping timeout!", serverAddress); + } catch (Exception e) { + log.warn("[ServerElection] server[{}] was down with unknown case!", serverAddress, e); } downServerCache.add(serverAddress); return null;