Skip to content

Commit 5700de6

Browse files
authored
reset metric (apache#15556)
1 parent 326432e commit 5700de6

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1659,6 +1659,8 @@ private void clear(boolean resetSyncIndex, boolean cleanBaseDir) {
16591659
try {
16601660
this.reqExecutionOrderBuffer.clear();
16611661
this.tsFileWriterPool.releaseAllWriters(consensusPipeName);
1662+
this.tsFileEventCount.set(0);
1663+
this.WALEventCount.set(0);
16621664
if (resetSyncIndex) {
16631665
this.onSyncedReplicateIndex = 0;
16641666
}

0 commit comments

Comments
 (0)