(iotdb) branch dev/1.3 updated: [To dev/1.3] Fix read lock not release when unexpected exception occurred. #16386

[jackietien]

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

jackietien pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 407802604ff [To dev/1.3] Fix read lock not release when unexpected 
exception occurred. #16386
407802604ff is described below

commit 407802604ff62ed9f28cc7b2ec411582ba94cd89
Author: Peng Junzhi <78788603+peng...@users.noreply.github.com>
AuthorDate: Wed Sep 10 19:48:44 2025 -0500

    [To dev/1.3] Fix read lock not release when unexpected exception occurred. 
#16386
    
    (cherry picked from commit 71603e5fd4d4345c55a87441795873015106f03f)
---
 .../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 25691e3f037..c1518fe5dad 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
@@ -2080,6 +2080,9 @@ public class DataRegion implements IDataRegionForQuery {
           clearAlreadyLockedList(needToUnLockList);
           Thread.currentThread().interrupt();
           return false;
+        } catch (Throwable throwable) {
+          clearAlreadyLockedList(needToUnLockList);
+          throw throwable;
         }
       }
     }
@@ -2127,6 +2130,9 @@ public class DataRegion implements IDataRegionForQuery {
           clearAlreadyLockedList(needToUnLockList);
           Thread.currentThread().interrupt();
           return false;
+        } catch (Throwable throwable) {
+          clearAlreadyLockedList(needToUnLockList);
+          throw throwable;
         }
       }
     }