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:48 UTC
(iotdb) branch enhance_log_for_getallregions created (now a05c0ec64bf)
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch enhance_log_for_getallregions
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at a05c0ec64bf finish
This branch includes the following new commits:
new a05c0ec64bf finish
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: finish
Posted by ta...@apache.org.
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)) {