From 9640d31cca55213bbaaf375b5f9d62a57e2961a0 Mon Sep 17 00:00:00 2001
From: starrocks-xupeng <xupeng@starrocks.com>
Date: Wed, 16 Oct 2024 14:12:18 +0800
Subject: [PATCH] [BugFix] fix random table select error when downgrade from
 3.3 to 3.2

Signed-off-by: starrocks-xupeng <xupeng@starrocks.com>
---
 .../main/java/com/starrocks/lake/StarMgrMetaSyncer.java  | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/fe/fe-core/src/main/java/com/starrocks/lake/StarMgrMetaSyncer.java b/fe/fe-core/src/main/java/com/starrocks/lake/StarMgrMetaSyncer.java
index 239b92bca350c..20a3cf8ec9afc 100644
--- a/fe/fe-core/src/main/java/com/starrocks/lake/StarMgrMetaSyncer.java
+++ b/fe/fe-core/src/main/java/com/starrocks/lake/StarMgrMetaSyncer.java
@@ -294,8 +294,13 @@ private boolean syncTableMetaInternal(Database db, OlapTable table, boolean forc
                 }
                 // no need to check db/table/partition again, everything still works
                 long groupId = physicalPartition.getShardGroupId();
-                List<Long> starmgrShardIds = starOSAgent.listShard(groupId);
-                Set<Long> starmgrShardIdsSet = new HashSet<>(starmgrShardIds);
+                Set<Long> starmgrShardIdsSet = null;
+                if (redundantGroupToShards.get(groupId) != null) {
+                    starmgrShardIdsSet = redundantGroupToShards.get(groupId);
+                } else {
+                    List<Long> starmgrShardIds = starOSAgent.listShard(groupId);
+                    starmgrShardIdsSet = new HashSet<>(starmgrShardIds);
+                }
                 for (MaterializedIndex materializedIndex :
                         physicalPartition.getMaterializedIndices(MaterializedIndex.IndexExtState.ALL)) {
                     for (Tablet tablet : materializedIndex.getTablets()) {