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 <[email protected]>
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();
}