This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch load_snapshot_leak in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 122b4d912dba11bd1bbafcee07416195acab8227 Author: OneSizeFitQuorum <[email protected]> AuthorDate: Wed May 29 10:19:42 2024 +0800 fix Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java index 218b80392ea..fd84a4b3bf9 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java @@ -817,8 +817,9 @@ public class StorageEngine implements IService { public void setDataRegion(DataRegionId regionId, DataRegion newRegion) { if (dataRegionMap.containsKey(regionId)) { DataRegion oldRegion = dataRegionMap.get(regionId); - oldRegion.syncCloseAllWorkingTsFileProcessors(); + oldRegion.markDeleted(); oldRegion.abortCompaction(); + oldRegion.syncCloseAllWorkingTsFileProcessors(); } dataRegionMap.put(regionId, newRegion); }
