This is an automated email from the ASF dual-hosted git repository. jermy pushed a commit to branch cassandra-metrics-ip6-fix in repository https://gitbox.apache.org/repos/asf/incubator-hugegraph.git
commit 5db9048dcdca1d557133573efbacdc4028f96d1b Author: Zhangmei Li <[email protected]> AuthorDate: Sun Apr 24 12:28:15 2022 +0800 log cassandra probe host Change-Id: Ida6b7f2675c86b6b241977075f0ef137a38fdd8d --- .../baidu/hugegraph/backend/store/cassandra/CassandraMetrics.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraMetrics.java b/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraMetrics.java index 0443a5f91..d2c54c7f4 100644 --- a/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraMetrics.java +++ b/hugegraph-cassandra/src/main/java/com/baidu/hugegraph/backend/store/cassandra/CassandraMetrics.java @@ -32,6 +32,7 @@ import org.apache.cassandra.metrics.CassandraMetricsRegistry.JmxTimerMBean; import org.apache.cassandra.tools.NodeProbe; import org.apache.cassandra.tools.nodetool.Compact; import org.apache.tinkerpop.gremlin.util.NumberHelper; +import org.slf4j.Logger; import com.baidu.hugegraph.backend.store.BackendMetrics; import com.baidu.hugegraph.backend.store.BackendTable; @@ -42,6 +43,7 @@ import com.baidu.hugegraph.config.HugeConfig; import com.baidu.hugegraph.testutil.Whitebox; import com.baidu.hugegraph.util.E; import com.baidu.hugegraph.util.InsertionOrderUtil; +import com.baidu.hugegraph.util.Log; import com.baidu.hugegraph.util.UnitUtil; import com.datastax.driver.core.Cluster; import com.datastax.driver.core.Host; @@ -49,6 +51,8 @@ import com.google.common.collect.ImmutableList; public class CassandraMetrics implements BackendMetrics { + private static final Logger LOG = Log.logger(CassandraMetrics.class); + private final Cluster cluster; private final int port; private final String username; @@ -299,6 +303,7 @@ public class CassandraMetrics implements BackendMetrics { } private NodeProbe newNodeProbe(String host) throws IOException { + LOG.info("Probe to cassandra node: '{}:{}'", host, this.port); return this.username.isEmpty() ? new NodeProbe(host, this.port) : new NodeProbe(host, this.port, this.username, this.password);
