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(

Reply via email to