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() {