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

jiangtian pushed a commit to branch native_raft
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/native_raft by this push:
     new f6294d4b81 Add member name in log of FlowBalancer
f6294d4b81 is described below

commit f6294d4b81229a04a4007b8cb6d4594845eb4bf8
Author: Tian Jiang <[email protected]>
AuthorDate: Wed May 17 12:19:48 2023 +0800

    Add member name in log of FlowBalancer
---
 .../natraft/protocol/log/dispatch/flowcontrol/FlowBalancer.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/flowcontrol/FlowBalancer.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/flowcontrol/FlowBalancer.java
index c2f9da50c0..a5b4296679 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/flowcontrol/FlowBalancer.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/flowcontrol/FlowBalancer.java
@@ -81,7 +81,7 @@ public class FlowBalancer {
 
   public void stop() {
     scheduledExecutorService.shutdownNow();
-    logger.info("Total burst duration: {}ms", burstDuration);
+    logger.info("{}: Total burst duration: {}ms", member.getName(), 
burstDuration);
   }
 
   private void rebalance() {

Reply via email to