[iotdb] branch FIDig updated: Fix Schema query memory don't free bug

[jackietien]

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

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


The following commit(s) were added to refs/heads/FIDig by this push:
     new 3ecb5b3379 Fix Schema query memory don't free bug
3ecb5b3379 is described below

commit 3ecb5b3379fa30e6ce3c7dab796fa442d4771a3f
Author: JackieTien97 <jackietie...@gmail.com>
AuthorDate: Thu Apr 6 11:26:24 2023 +0800

    Fix Schema query memory don't free bug
---
 .../mpp/execution/fragment/FragmentInstanceContext.java  | 16 +++++++++++-----
 1 file changed, 11 insertions(+), 5 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceContext.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceContext.java
index f810bc1ddb..5fd3ed785e 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceContext.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceContext.java
@@ -355,13 +355,19 @@ public class FragmentInstanceContext extends QueryContext 
{
    * be decreased.
    */
   protected synchronized void releaseResource() {
-    for (TsFileResource tsFile : closedFilePaths) {
-      FileReaderManager.getInstance().decreaseFileReaderReference(tsFile, 
true);
+    // for schema related FI, closedFilePaths and unClosedFilePaths will be 
null
+    if (closedFilePaths != null) {
+      for (TsFileResource tsFile : closedFilePaths) {
+        FileReaderManager.getInstance().decreaseFileReaderReference(tsFile, 
true);
+      }
+      closedFilePaths = null;
     }
-    closedFilePaths = null;
-    for (TsFileResource tsFile : unClosedFilePaths) {
-      FileReaderManager.getInstance().decreaseFileReaderReference(tsFile, 
false);
+    if (unClosedFilePaths != null) {
+      for (TsFileResource tsFile : unClosedFilePaths) {
+        FileReaderManager.getInstance().decreaseFileReaderReference(tsFile, 
false);
+      }
     }
+
     unClosedFilePaths = null;
     dataRegion = null;
     timeFilter = null;