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
commit 1c1171f0a810b5e48c1746486b66bee83f204495 Author: LebronAl <[email protected]> AuthorDate: Tue Nov 9 20:17:49 2021 +0800 add cluster query log --- .../org/apache/iotdb/cluster/query/manage/ClusterQueryManager.java | 6 ++++++ .../src/main/java/org/apache/iotdb/cluster/server/ClientServer.java | 2 ++ 2 files changed, 8 insertions(+) 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 f3376ba..cbd6fa0 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 @@ -28,6 +28,9 @@ import org.apache.iotdb.db.query.reader.series.IAggregateReader; import org.apache.iotdb.db.query.reader.series.IReaderByTimestamp; import org.apache.iotdb.tsfile.read.reader.IBatchReader; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + import java.util.HashMap; import java.util.Map; import java.util.Set; @@ -36,6 +39,7 @@ import java.util.concurrent.atomic.AtomicLong; public class ClusterQueryManager { + private static final Logger logger = LoggerFactory.getLogger(ClusterQueryManager.class); private AtomicLong idAtom = new AtomicLong(); private Map<Node, Map<Long, RemoteQueryContext>> queryContextMap = new ConcurrentHashMap<>(); private Map<Long, IBatchReader> seriesReaderMap = new ConcurrentHashMap<>(); @@ -46,6 +50,7 @@ public class ClusterQueryManager { public synchronized RemoteQueryContext getQueryContext(Node node, long queryId) { Map<Long, RemoteQueryContext> nodeContextMap = queryContextMap.computeIfAbsent(node, n -> new HashMap<>()); + logger.warn("regist queryId {} from Node {}", queryId, node); return nodeContextMap.computeIfAbsent( queryId, qId -> new RemoteQueryContext(QueryResourceManager.getInstance().assignQueryId(true))); @@ -64,6 +69,7 @@ public class ClusterQueryManager { } public synchronized void endQuery(Node node, long queryId) throws StorageEngineException { + logger.warn("end queryId {} from Node {}", queryId, node); Map<Long, RemoteQueryContext> nodeContextMap = queryContextMap.get(node); if (nodeContextMap == null) { return; diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/ClientServer.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/ClientServer.java index ec2c523..107624f 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/server/ClientServer.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/ClientServer.java @@ -292,6 +292,7 @@ public class ClientServer extends TSServiceImpl { protected QueryContext genQueryContext(long queryId, boolean debug) { RemoteQueryContext context = new RemoteQueryContext(queryId, debug); queryContextMap.put(queryId, context); + logger.warn("regist queryid {}", queryId); return context; } @@ -308,6 +309,7 @@ public class ClientServer extends TSServiceImpl { // release resources remotely RemoteQueryContext context = queryContextMap.remove(queryId); if (context != null) { + logger.warn("release queryid {}", queryId); // release the resources in every queried node for (Entry<Node, Set<Node>> headerEntry : context.getQueriedNodesMap().entrySet()) { Node header = headerEntry.getKey();
