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/07/29 11:11:20 UTC
[iotdb] branch ml_0729_test updated: add more log
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch ml_0729_test
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/ml_0729_test by this push:
new e0382b5c59 add more log
e0382b5c59 is described below
commit e0382b5c59d507e6e7e661a2fbb2558befeef4ef
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Fri Jul 29 19:11:08 2022 +0800
add more log
---
.../iotdb/db/consensus/statemachine/DataRegionStateMachine.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
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 2db1a8b204..adad0a8b98 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
@@ -136,7 +136,9 @@ public class DataRegionStateMachine extends BaseStateMachine {
}
}
cacheCondition.signalAll();
- return requestCache.poll().getInsertNode();
+ InsertNodeWrapper wrapper = requestCache.poll();
+ logger.info("queue size {}, syncIndex = {}", requestCache.size(), wrapper.getSyncIndex());
+ return wrapper.getInsertNode();
} finally {
lock.unlock();
}