Skip to content

Commit 50f7ec5

Browse files
committed
feat:optimize heartbeat and re-register.
1 parent 3f1fde4 commit 50f7ec5

File tree

1 file changed

+6
-8
lines changed
  • polaris-discovery/polaris-discovery-client/src/main/java/com/tencent/polaris/discovery/client/flow

1 file changed

+6
-8
lines changed

polaris-discovery/polaris-discovery-client/src/main/java/com/tencent/polaris/discovery/client/flow/RegisterFlow.java

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -92,19 +92,17 @@ void doRunHeartbeat(RegisterState registerState, RegisterFunction registerFuncti
9292
} catch (PolarisException e) {
9393
if (e.getServerErrCode() == ServerCodes.NOT_FOUND_RESOURCE) {
9494
registerState.incrementFailCount();
95-
LOG.debug("[AsyncHeartbeat]Instance heartbeat failed because of NOT_FOUND_RESOURCE. Increase fail count. namespace:{}, service:{}, host:{}, port:{}, heartbeat fail count:{}",
95+
LOG.error("[AsyncHeartbeat]Instance heartbeat failed because of NOT_FOUND_RESOURCE. Increase fail count. " +
96+
"namespace:{}, service:{}, host:{}, port:{}, heartbeat fail count:{}",
9697
registerRequest.getNamespace(), registerRequest.getService(), registerRequest.getHost(),
97-
registerRequest.getPort(), registerState.getHeartbeatFailCounter());
98+
registerRequest.getPort(), registerState.getHeartbeatFailCounter(), e);
9899
} else {
99100
registerState.resetFailCount();
100-
LOG.debug("[AsyncHeartbeat]Instance heartbeat failed not because of NOT_FOUND_RESOURCE. Reset fail count. namespace:{}, service:{}, host:{}, port:{}, heartbeat fail count:{}",
101+
LOG.error("[AsyncHeartbeat]Instance heartbeat failed not because of NOT_FOUND_RESOURCE. Reset fail count. " +
102+
"namespace:{}, service:{}, host:{}, port:{}, heartbeat fail count:{}",
101103
registerRequest.getNamespace(), registerRequest.getService(), registerRequest.getHost(),
102-
registerRequest.getPort(), registerState.getHeartbeatFailCounter());
104+
registerRequest.getPort(), registerState.getHeartbeatFailCounter(), e);
103105
}
104-
LOG.error(
105-
"[AsyncHeartbeat]Instance heartbeat failed, namespace:{}, service:{}, host:{}, port:{}, heartbeat fail count:{}",
106-
registerRequest.getNamespace(), registerRequest.getService(), registerRequest.getHost(),
107-
registerRequest.getPort(), registerState.getHeartbeatFailCounter(), e);
108106
}
109107

110108
long minRegisterInterval = sdkContext.getConfig().getProvider().getMinRegisterInterval();

0 commit comments

Comments
 (0)