[iotdb] branch ml_0808_test_exp1_parallel updated: add log for processor

[xingtanzjr]

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

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


The following commit(s) were added to refs/heads/ml_0808_test_exp1_parallel by 
this push:
     new ae36750f0f add log for processor
ae36750f0f is described below

commit ae36750f0f07b6d0df9741fab3d8604cee8c8e86
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Mon Aug 8 16:39:09 2022 +0800

    add log for processor
---
 .../apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
 
b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
index c5fa31a9ca..8380cf50c3 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
@@ -118,6 +118,7 @@ public class DataRegionStateMachine extends 
BaseStateMachine {
 
   private TSStatus cacheAndInsertLatestNode(long syncIndex, InsertNode 
insertNode) {
     long cacheRequestStartTime = System.nanoTime();
+    logger.info("syncIndex = {}, nextSyncIndex = {}", syncIndex, 
nextSyncIndex);
     insertNode.setSyncIndex(syncIndex);
     synchronized (requestCache) {
       requestCache.add(insertNode);
@@ -190,11 +191,9 @@ public class DataRegionStateMachine extends 
BaseStateMachine {
           insertNodes.add(innerNode);
         }
         if (indexedRequest.getSearchIndex() == 
ConsensusReqReader.DEFAULT_SEARCH_INDEX) {
-
           TSStatus status =
               cacheAndInsertLatestNode(
                   indexedRequest.getSyncIndex(), 
mergeInsertNodes(insertNodes));
-
           return status;
         } else {
           planNode = mergeInsertNodes(insertNodes);