[iotdb] branch rel_0.12_debug_compaction_stop updated: add detail log

[ta...@apache.org]

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

tanxinyu pushed a commit to branch rel_0.12_debug_compaction_stop
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel_0.12_debug_compaction_stop by this push:
     new 29b9183  add detail log
29b9183 is described below

commit 29b91830001b9d6aa0ca4be71496a35cf23b940d
Author: LebronAl <TX...@gmail.com>
AuthorDate: Wed Nov 10 11:38:23 2021 +0800

    add detail log
---
 .../main/java/org/apache/iotdb/cluster/query/LocalQueryExecutor.java | 2 +-
 .../org/apache/iotdb/cluster/query/manage/ClusterQueryManager.java   | 5 ++++-
 .../java/org/apache/iotdb/db/engine/storagegroup/TsFileResource.java | 2 ++
 3 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/query/LocalQueryExecutor.java b/cluster/src/main/java/org/apache/iotdb/cluster/query/LocalQueryExecutor.java
index 74a2721..1fefc79 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/query/LocalQueryExecutor.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/query/LocalQueryExecutor.java
@@ -756,7 +756,7 @@ public class LocalQueryExecutor {
       timeFilter = FilterFactory.deserialize(request.timeFilterBytes);
     }
     long queryId = request.getQueryId();
-    logger.debug(
+    logger.warn(
         "{}: {} is querying {} using group by, queryId: {}",
         name,
         request.getRequestor(),
diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/query/manage/ClusterQueryManager.java b/cluster/src/main/java/org/apache/iotdb/cluster/query/manage/ClusterQueryManager.java
index cbd6fa0..d43cb19 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/query/manage/ClusterQueryManager.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/query/manage/ClusterQueryManager.java
@@ -69,17 +69,20 @@ public class ClusterQueryManager {
   }
 
   public synchronized void endQuery(Node node, long queryId) throws StorageEngineException {
-    logger.warn("end queryId {} from Node {}", queryId, node);
+    logger.warn("end queryId before {} from Node {}", queryId, node);
     Map<Long, RemoteQueryContext> nodeContextMap = queryContextMap.get(node);
     if (nodeContextMap == null) {
+      logger.error("nodeContextMap is null queryId {} from Node {}", queryId, node);
       return;
     }
     RemoteQueryContext remoteQueryContext = nodeContextMap.remove(queryId);
     if (remoteQueryContext == null) {
+      logger.error("remoteQueryContext is null queryId {} from Node {}", queryId, node);
       return;
     }
     // release file resources
     QueryResourceManager.getInstance().endQuery(remoteQueryContext.getQueryId());
+    logger.warn("end queryId after {} from Node {}", queryId, node);
 
     // remove the readers from the cache
     Set<Long> readerIds = remoteQueryContext.getLocalReaderIds();
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileResource.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileResource.java
index 2a8dd63..14fb1fa 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileResource.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileResource.java
@@ -461,6 +461,8 @@ public class TsFileResource {
       originTsFileResource.readUnlock(holder);
     }
     readLockHolders.remove(holder);
+    logger.warn("read unlock stack of {}", holder, new RuntimeException("readLock"));
+    logger.info("{} release the read lock of  {}", holder, this.file);
   }
 
   public boolean tryWriteLock(String holder) {