alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-5141 Should be sleep with REGISTRATION_RETRY_DELAY when registry MBean failed

Browse Source
This commit is contained in:
harveyyue 2022-05-18 13:49:19 +08:00 committed by Jiri Pechanec
parent c762143178
commit f66b07cd80
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
debezium-core/src/main/java/io/debezium/metrics/Metrics.java
View File

@ -25,7 +25,9 @@
import io.debezium.annotation.ThreadSafe;
import io.debezium.config.CommonConnectorConfig;
import io.debezium.connector.common.CdcSourceTaskContext;
import io.debezium.util.Clock;
import io.debezium.util.Collect;
import io.debezium.util.Metronome;
/**
* Base for metrics implementations.
@ -86,10 +88,12 @@ public synchronized void register() {
break;
}
catch (InstanceAlreadyExistsException e) {
if (attempt <= REGISTRATION_RETRIES) {
if (attempt < REGISTRATION_RETRIES) {
LOGGER.warn(
"Unable to register metrics as an old set with the same name exists, retrying in {} (attempt {} out of {})",
REGISTRATION_RETRY_DELAY, attempt, REGISTRATION_RETRIES);
final Metronome metronome = Metronome.sleeper(REGISTRATION_RETRY_DELAY, Clock.system());
metronome.pause();
}
else {
LOGGER.error("Failed to register metrics MBean, metrics will not be available");
@ -100,7 +104,7 @@ public synchronized void register() {
// upon shutdown.
registered = true;
}
catch (JMException e) {
catch (JMException | InterruptedException e) {
throw new RuntimeException("Unable to register the MBean '" + name + "'", e);
}
}