This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev/1.3 by this push:
new 7363869a793 Remove useless log "datanodeId -1" #14035 (#14055)
7363869a793 is described below
commit 7363869a7937cc9539087f2c899fc374c1975744
Author: Li Yu Heng <[email protected]>
AuthorDate: Tue Nov 12 14:18:34 2024 +0800
Remove useless log "datanodeId -1" #14035 (#14055)
---
.../apache/iotdb/confignode/manager/load/balancer/RouteBalancer.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/RouteBalancer.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/RouteBalancer.java
index 350aa783360..758c05f2c1e 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/RouteBalancer.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/RouteBalancer.java
@@ -264,6 +264,9 @@ public class RouteBalancer implements
IClusterStatusSubscriber {
entry -> {
// set target
final Integer dataNodeId = entry.getValue();
+ if (dataNodeId == -1) {
+ return;
+ }
final TDataNodeLocation dataNodeLocation =
getNodeManager().getRegisteredDataNode(dataNodeId).getLocation();
if (dataNodeLocation == null) {
