Skip to content

Commit 4e2fb58

Browse files
authored
add debug entry (#15694)
1 parent 7d5b7c5 commit 4e2fb58

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -126,6 +126,7 @@ public class IoTConsensusServerImpl {
126126
private final ScheduledExecutorService backgroundTaskService;
127127
private final IoTConsensusRateLimiter ioTConsensusRateLimiter =
128128
IoTConsensusRateLimiter.getInstance();
129+
private IndexedConsensusRequest lastConsensusRequest;
129130

130131
public IoTConsensusServerImpl(
131132
String storageDir,
@@ -208,12 +209,14 @@ public TSStatus write(IConsensusRequest request) {
208209
writeToStateMachineStartTime - getStateMachineLockTime);
209210
IndexedConsensusRequest indexedConsensusRequest =
210211
buildIndexedConsensusRequestForLocalRequest(request);
212+
lastConsensusRequest = indexedConsensusRequest;
211213
if (indexedConsensusRequest.getSearchIndex() % 100000 == 0) {
212214
logger.info(
213-
"DataRegion[{}]: index after build: safeIndex:{}, searchIndex: {}",
215+
"DataRegion[{}]: index after build: safeIndex:{}, searchIndex: {}, lastConsensusRequest: {}",
214216
thisNode.getGroupId(),
215217
getMinSyncIndex(),
216-
indexedConsensusRequest.getSearchIndex());
218+
indexedConsensusRequest.getSearchIndex(),
219+
lastConsensusRequest.getSerializedRequests());
217220
}
218221
IConsensusRequest planNode = stateMachine.deserializeRequest(indexedConsensusRequest);
219222
long startWriteTime = System.nanoTime();

0 commit comments

Comments
 (0)