Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
shuwenwei committed Dec 20, 2024
1 parent e1781ef commit fae4b1c
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,7 @@
import org.apache.iotdb.db.queryengine.plan.analyze.cache.schema.DataNodeTTLCache;
import org.apache.iotdb.db.queryengine.plan.planner.plan.node.load.LoadTsFilePieceNode;
import org.apache.iotdb.db.queryengine.plan.scheduler.load.LoadTsFileScheduler;
import org.apache.iotdb.db.service.metrics.FileMetrics;
import org.apache.iotdb.db.service.metrics.WritingMetrics;
import org.apache.iotdb.db.storageengine.buffer.BloomFilterCache;
import org.apache.iotdb.db.storageengine.buffer.ChunkCache;
Expand Down Expand Up @@ -750,6 +751,7 @@ public void deleteDataRegion(DataRegionId regionId) {
deletingDataRegionMap.computeIfAbsent(regionId, k -> dataRegionMap.remove(regionId));
if (region != null) {
region.markDeleted();
FileMetrics.getInstance().deleteRegion(region.getDatabaseName(), region.getDataRegionId());
WRITING_METRICS.removeDataRegionMemoryCostMetrics(regionId);
WRITING_METRICS.removeFlushingMemTableStatusMetrics(regionId);
WRITING_METRICS.removeActiveMemtableCounterMetrics(regionId);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3724,7 +3724,6 @@ public void markDeleted() {
try {
deleted = true;
releaseDirectBufferMemory();
FileMetrics.getInstance().deleteRegion(databaseName, dataRegionId);
MetricService.getInstance().removeMetricSet(metrics);
deletedCondition.signalAll();
} finally {
Expand Down

0 comments on commit fae4b1c

Please sign in to comment.