[iotdb] branch xingtanzjr/query_retry updated: add more logs

[xi...@apache.org]

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

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


The following commit(s) were added to refs/heads/xingtanzjr/query_retry by this push:
     new 395809c4e0 add more logs
395809c4e0 is described below

commit 395809c4e04bdfbc79562604ae0b7c65e88f0db4
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Thu Jul 14 10:58:35 2022 +0800

    add more logs
---
 .../confignode/service/thrift/ConfigNodeRPCServiceProcessor.java     | 4 +++-
 .../org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCache.java   | 5 +++++
 2 files changed, 8 insertions(+), 1 deletion(-)

diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java b/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
index f61f411619..769da29d63 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
@@ -542,7 +542,9 @@ public class ConfigNodeRPCServiceProcessor implements IConfigNodeRPCService.Ifac
 
   @Override
   public TRegionRouteMapResp getLatestRegionRouteMap() throws TException {
-    return configManager.getLatestRegionRouteMap();
+    TRegionRouteMapResp resp = configManager.getLatestRegionRouteMap();
+    LOGGER.info("GetLatestRegionRouteMap. return: {}", resp);
+    return resp;
   }
 
   @Override
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCache.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCache.java
index bb9481570a..f64438f7f3 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCache.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCache.java
@@ -155,6 +155,7 @@ public class PartitionCache {
           }
         };
     getStorageGroupCacheResult(result, devicePaths, isAutoCreate);
+    logger.info("result.getMap: {}", result.getMap());
     return result.getMap();
   }
 
@@ -381,6 +382,7 @@ public class PartitionCache {
   // endregion
 
   // region replicaSet cache
+
   /**
    * get regionReplicaSet from local and confignode
    *
@@ -566,6 +568,7 @@ public class PartitionCache {
     try {
       if (storageGroupToQueryParamsMap.size() == 0) {
         CacheMetricsRecorder.record(false, DATA_PARTITION_CACHE_NAME);
+        logger.info("storageGroupToQueryParamsMap is empty");
         return null;
       }
       Map<String, Map<TSeriesPartitionSlot, Map<TTimePartitionSlot, List<TRegionReplicaSet>>>>
@@ -575,6 +578,8 @@ public class PartitionCache {
           storageGroupToQueryParamsMap.entrySet()) {
         if (!getStorageGroupDataPartition(dataPartitionMap, entry.getKey(), entry.getValue())) {
           CacheMetricsRecorder.record(false, DATA_PARTITION_CACHE_NAME);
+          logger.info(
+              "getStorageGroupDataPartition. Key: {}, value: {}", entry.getKey(), entry.getValue());
           return null;
         }
       }