You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2025/02/13 06:33:49 UTC
(iotdb) 01/01: finish
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch enhance_log_for_getallregions
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit a05c0ec64bfc25ca15fa70f1acb44ffc2d29d153
Author: OneSizeFitQuorum <ta...@apache.org>
AuthorDate: Thu Feb 13 14:33:32 2025 +0800
finish
Signed-off-by: OneSizeFitQuorum <ta...@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 370210da5ea..2d8a3782c3b 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
@@ -1806,9 +1806,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());
+ break;
}
}
-
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 a51c7b1a8bd..971f468e18f 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
@@ -549,6 +549,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)) {