You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/08/08 08:39:21 UTC
[iotdb] branch ml_0808_test_exp1_parallel updated: add log for processor
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 <xi...@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);