(iotdb) branch dev/1.3 updated: Enhance getLatestRegionRouteMap log for debugging #14830 (#14842)

[tanxinyu]

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

tanxinyu 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 0097a85ef50 Enhance getLatestRegionRouteMap log for debugging #14830 
(#14842)
0097a85ef50 is described below

commit 0097a85ef50b0767a7c5d923ee738b6d56109830
Author: Potato <tanxi...@apache.org>
AuthorDate: Fri Feb 14 16:05:09 2025 +0800

    Enhance getLatestRegionRouteMap log for debugging #14830 (#14842)
    
    Signed-off-by: OneSizeFitQuorum <tanxi...@apache.org>
---
 .../main/java/org/apache/iotdb/confignode/manager/ConfigManager.java | 3 ++-
 .../db/queryengine/plan/analyze/cache/partition/PartitionCache.java  | 5 +++++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
index 8ef20f9b709..d9b5aa422ab 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
@@ -1731,9 +1731,10 @@ public class ConfigManager implements IManager {
         } catch (InterruptedException e) {
           Thread.currentThread().interrupt();
           LOGGER.warn("Unexpected interruption during retry getting latest 
region route map");
+          
resp.getStatus().setCode(TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode());
+          return resp;
         }
       }
-
       resp.setTimestamp(System.currentTimeMillis());
       resp.setRegionRouteMap(getLoadManager().getRegionPriorityMap());
     }
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/PartitionCache.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/PartitionCache.java
index 91785849e76..1d8e8b38a49 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/PartitionCache.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/PartitionCache.java
@@ -461,6 +461,11 @@ public class PartitionCache {
             TRegionRouteMapResp resp = client.getLatestRegionRouteMap();
             if (TSStatusCode.SUCCESS_STATUS.getStatusCode() == 
resp.getStatus().getCode()) {
               updateGroupIdToReplicaSetMap(resp.getTimestamp(), 
resp.getRegionRouteMap());
+            } else {
+              logger.warn(
+                  "Unexpected error when getRegionReplicaSet: status {}， 
regionMap: {}",
+                  resp.getStatus(),
+                  resp.getRegionRouteMap());
             }
             // if confignode don't have then will throw RuntimeException
             if (!groupIdToReplicaSetMap.containsKey(consensusGroupId)) {