(iotdb) branch master updated: Fix ConcurrentModificationException when evict time partition info (#11907)

[haonan]

This is an automated email from the ASF dual-hosted git repository.

haonan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new f1d87533610 Fix ConcurrentModificationException when evict time 
partition info (#11907)
f1d87533610 is described below

commit f1d87533610d9950726158a55f6e3829c7392ea9
Author: Haonan <hhao...@outlook.com>
AuthorDate: Tue Jan 16 17:37:05 2024 +0800

    Fix ConcurrentModificationException when evict time partition info (#11907)
---
 .../org/apache/iotdb/db/storageengine/dataregion/DataRegion.java   | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
index 07e77095542..e3b03e31eb4 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -3398,7 +3398,12 @@ public class DataRegion implements IDataRegionForQuery {
   }
 
   public void releaseFlushTimeMap(long timePartitionId) {
-    lastFlushTimeMap.removePartition(timePartitionId);
+    writeLock("releaseFlushTimeMap");
+    try {
+      lastFlushTimeMap.removePartition(timePartitionId);
+    } finally {
+      writeUnlock();
+    }
   }
 
   public long getMemCost() {