(iotdb) branch master updated: Fix read lock not release when unexpected exception occurred. (#16385)

[jackietien]

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

jackietien 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 71603e5fd4d Fix read lock not release when unexpected exception 
occurred. (#16385)
71603e5fd4d is described below

commit 71603e5fd4d4345c55a87441795873015106f03f
Author: Peng Junzhi <78788603+peng...@users.noreply.github.com>
AuthorDate: Wed Sep 10 04:30:37 2025 -0500

    Fix read lock not release when unexpected exception occurred. (#16385)
---
 .../org/apache/iotdb/db/storageengine/dataregion/DataRegion.java    | 6 ++++++
 1 file changed, 6 insertions(+)

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 5a2669a8767..d88085974af 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
@@ -2196,6 +2196,9 @@ public class DataRegion implements IDataRegionForQuery {
           clearAlreadyLockedList(needToUnLockList);
           Thread.currentThread().interrupt();
           return false;
+        } catch (Throwable throwable) {
+          clearAlreadyLockedList(needToUnLockList);
+          throw throwable;
         }
       }
     }
@@ -2239,6 +2242,9 @@ public class DataRegion implements IDataRegionForQuery {
           clearAlreadyLockedList(needToUnLockList);
           Thread.currentThread().interrupt();
           return false;
+        } catch (Throwable throwable) {
+          clearAlreadyLockedList(needToUnLockList);
+          throw throwable;
         }
       }
     }