You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2023/03/13 11:09:09 UTC
[rocketmq-clients] 02/02: Increase metric exporter RPC timeout to 5 seconds
This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 7849cbcefeff7295d94d8638c50a3ceacf63435a
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Mon Mar 13 18:59:51 2023 +0800
Increase metric exporter RPC timeout to 5 seconds
---
.../org/apache/rocketmq/client/java/metrics/ClientMeterManager.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterManager.java b/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterManager.java
index deaaad32..22ec939a 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterManager.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterManager.java
@@ -51,7 +51,7 @@ import org.slf4j.LoggerFactory;
public class ClientMeterManager {
private static final Logger log = LoggerFactory.getLogger(ClientMeterManager.class);
- private static final Duration METRIC_EXPORTER_RPC_TIMEOUT = Duration.ofSeconds(3);
+ private static final Duration METRIC_EXPORTER_RPC_TIMEOUT = Duration.ofSeconds(5);
private static final Duration METRIC_READER_INTERVAL = Duration.ofMinutes(1);
private static final String METRIC_INSTRUMENTATION_NAME = "org.apache.rocketmq.message";
@@ -170,7 +170,7 @@ public class ClientMeterManager {
})) {
log.debug("Build observable double gauge successfully, gauge={}, clientId={}", name, clientId);
} catch (Exception e) {
- log.error("Failed to build observable double gauge, gauge={}, clientId={}", name, clientId);
+ log.error("Failed to build observable double gauge, gauge={}, clientId={}", name, clientId, e);
}
}
} catch (Throwable t) {