diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java index 83cdbeb27fec5..9c46ba9b7a67c 100644 --- a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java +++ b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java @@ -126,6 +126,7 @@ public class IoTConsensusServerImpl { private final ScheduledExecutorService backgroundTaskService; private final IoTConsensusRateLimiter ioTConsensusRateLimiter = IoTConsensusRateLimiter.getInstance(); + private IndexedConsensusRequest lastConsensusRequest; public IoTConsensusServerImpl( String storageDir, @@ -208,12 +209,14 @@ public TSStatus write(IConsensusRequest request) { writeToStateMachineStartTime - getStateMachineLockTime); IndexedConsensusRequest indexedConsensusRequest = buildIndexedConsensusRequestForLocalRequest(request); + lastConsensusRequest = indexedConsensusRequest; if (indexedConsensusRequest.getSearchIndex() % 100000 == 0) { logger.info( - "DataRegion[{}]: index after build: safeIndex:{}, searchIndex: {}", + "DataRegion[{}]: index after build: safeIndex:{}, searchIndex: {}, lastConsensusRequest: {}", thisNode.getGroupId(), getMinSyncIndex(), - indexedConsensusRequest.getSearchIndex()); + indexedConsensusRequest.getSearchIndex(), + lastConsensusRequest.getSerializedRequests()); } IConsensusRequest planNode = stateMachine.deserializeRequest(indexedConsensusRequest); long startWriteTime = System.nanoTime();