This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch iotdb-3791
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/iotdb-3791 by this push:
new 6d27cf0b71 add batch size count
6d27cf0b71 is described below
commit 6d27cf0b71f98d920ba97a4f1e670f87762b69e3
Author: Jinrui.Zhang <[email protected]>
AuthorDate: Thu Jul 14 20:35:53 2022 +0800
add batch size count
---
.../consensus/multileader/service/MultiLeaderRPCServiceProcessor.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
index 87555bbea0..07849f86bd 100644
---
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
+++
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
@@ -71,6 +71,7 @@ public class MultiLeaderRPCServiceProcessor implements
MultiLeaderConsensusIServ
List<TSStatus> statuses = new ArrayList<>();
// We use synchronized to ensure atomicity of executing multiple logs
synchronized (impl.getStateMachine()) {
+ StepTracker.trace("req.getBatches().size()", 10, 0,
req.getBatches().size() * 1000_000L);
for (TLogBatch batch : req.getBatches()) {
long writeOneBatch = System.nanoTime();
statuses.add(