[iotdb] branch beyyes/confignode_develop updated: fix import errors

[caogaofei]

This is an automated email from the ASF dual-hosted git repository.

caogaofei pushed a commit to branch beyyes/confignode_develop
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/beyyes/confignode_develop by 
this push:
     new 043df3b746 fix import errors
043df3b746 is described below

commit 043df3b74675bb076f39183c35bfe1b7dcc3fd72
Author: Beyyes <cgf1...@foxmail.com>
AuthorDate: Mon Aug 1 15:28:43 2022 +0800

    fix import errors
---
 .../client/async/handlers/DataNodeHeartbeatHandler.java       | 11 ++++++-----
 .../confignode/manager/load/balancer/router/LeaderRouter.java |  5 ++++-
 2 files changed, 10 insertions(+), 6 deletions(-)

diff --git 
a/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/DataNodeHeartbeatHandler.java
 
b/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/DataNodeHeartbeatHandler.java
index 1e2832a911..78325717b1 100644
--- 
a/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/DataNodeHeartbeatHandler.java
+++ 
b/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/DataNodeHeartbeatHandler.java
@@ -62,11 +62,12 @@ public class DataNodeHeartbeatHandler implements 
AsyncMethodCallback<THeartbeatR
     // Update RegionCache
     if (heartbeatResp.isSetJudgedLeaders()) {
       LOGGER.info(
-          "DataNodeHeartbeatHandler complete, heartBeatTime: {}, receiveTime: 
{}, dataNode: {}, judgeLeaders: {}",
-          heartbeatResp.getHeartbeatTimestamp(),
-          receiveTime,
-          dataNodeLocation.getDataNodeId(),
-          heartbeatResp.getJudgedLeaders());
+          String.format(
+              "DataNodeHeartbeatHandler complete, heartBeatTime: %s, 
receiveTime: %s, dataNode: %s, judgeLeaders: %s",
+              heartbeatResp.getHeartbeatTimestamp(),
+              receiveTime,
+              dataNodeLocation.getDataNodeId(),
+              heartbeatResp.getJudgedLeaders()));
       heartbeatResp
           .getJudgedLeaders()
           .forEach(
diff --git 
a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LeaderRouter.java
 
b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LeaderRouter.java
index dcfc1726b8..19709de7c5 100644
--- 
a/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LeaderRouter.java
+++ 
b/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LeaderRouter.java
@@ -26,7 +26,10 @@ import org.apache.iotdb.tsfile.utils.Pair;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Comparator;
+import java.util.List;
+import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.stream.Collectors;