fix

miyuan-ljr · miyuan-ljr · commit 395261f4f5bf · 2024-11-08T17:46:57.000+08:00
diff --git a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java
@@ -1956,8 +1956,11 @@ private List<ObPair<Long, ReplicaLocation>> getPartitionReplica(TableEntry table
             }
         } else {
             for (Long partId : partIds) {
-                long partitionId = ObPartIdCalculator.getPartIdx(partId, tableEntry
-                        .getPartitionInfo().getSubPartDesc().getPartNum());
+                long partitionId = partId;
+                if (tableEntry.getPartitionInfo().getLevel() == ObPartitionLevel.LEVEL_TWO) {
+                    partitionId = ObPartIdCalculator.getPartIdx(partId, tableEntry
+                            .getPartitionInfo().getSubPartDesc().getPartNum());
+                }
                 replicas.add(new ObPair<Long, ReplicaLocation>(partId, getPartitionLocation(
                         tableEntry, partitionId, route)));
             }

Original file line number	Diff line number	Diff line change
`@@ -1956,8 +1956,11 @@ private List<ObPair<Long, ReplicaLocation>> getPartitionReplica(TableEntry table`
`1956`	`1956`	`}`
`1957`	`1957`	`} else {`
`1958`	`1958`	`for (Long partId : partIds) {`
`1959`		`- long partitionId = ObPartIdCalculator.getPartIdx(partId, tableEntry`
`1960`		`- .getPartitionInfo().getSubPartDesc().getPartNum());`
	`1959`	`+ long partitionId = partId;`
	`1960`	`+ if (tableEntry.getPartitionInfo().getLevel() == ObPartitionLevel.LEVEL_TWO) {`
	`1961`	`+ partitionId = ObPartIdCalculator.getPartIdx(partId, tableEntry`
	`1962`	`+ .getPartitionInfo().getSubPartDesc().getPartNum());`
	`1963`	`+ }`
`1961`	`1964`	`replicas.add(new ObPair<Long, ReplicaLocation>(partId, getPartitionLocation(`
`1962`	`1965`	`tableEntry, partitionId, route)));`
`1963`	`1966`	`}`