Skip to content

Commit b9039ba

Browse files
committed
Update PipeDataRegionAssigner.java
1 parent f273c51 commit b9039ba

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/assigner/PipeDataRegionAssigner.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -189,6 +189,8 @@ public boolean notMoreExtractorNeededToBeAssigned() {
189189
// use synchronized here for completely preventing reference count leaks under extreme thread
190190
// scheduling when closing
191191
public synchronized void close() {
192+
PipeAssignerMetrics.getInstance().deregister(dataRegionId);
193+
192194
final long startTime = System.currentTimeMillis();
193195
disruptor.shutdown();
194196
matcher.clear();

0 commit comments

Comments
 (0)