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 12510f2e39 add log for region id
12510f2e39 is described below
commit 12510f2e39cc342b81126d7e3ef8b2f46aa4bc46
Author: Jinrui.Zhang <[email protected]>
AuthorDate: Tue Aug 9 13:40:08 2022 +0800
add log for region id
---
.../iotdb/db/consensus/statemachine/DataRegionStateMachine.java | 5 ++++-
1 file changed, 4 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 0098c69975..331bb7a634 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
@@ -125,7 +125,10 @@ public class DataRegionStateMachine extends
BaseStateMachine {
private TSStatus cacheAndInsertLatestNode(InsertNodeWrapper
insertNodeWrapper) {
long cacheRequestStartTime = System.nanoTime();
logger.info(
- "syncIndex = {}, nextSyncIndex = {}",
insertNodeWrapper.startSyncIndex, nextSyncIndex);
+ "region = {}, syncIndex = {}, nextSyncIndex = {}",
+ region.getDataRegionId(),
+ insertNodeWrapper.startSyncIndex,
+ nextSyncIndex);
queueLock.lock();
try {
requestCache.add(insertNodeWrapper);