Skip to content

Commit d51acc5

Browse files
committed
fix global index route wrong
1 parent 2af40bc commit d51acc5

File tree

3 files changed

+5
-6
lines changed

3 files changed

+5
-6
lines changed

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ protected ObPayload commonExecute(ObTableClient client, Logger logger,
155155
result = subObTable.executeWithConnection(request, connectionRef);
156156
} else {
157157
result = subObTable.execute(request);
158-
158+
System.err.println("indexTableName:" +indexTableName);
159159
if (result != null && result.getPcode() == Pcodes.OB_TABLE_API_MOVE) {
160160
ObTableApiMove moveResponse = (ObTableApiMove) result;
161161
client.getRouteTableRefresher().addTableIfAbsent(indexTableName, true);
@@ -376,7 +376,6 @@ protected Map<Long, ObPair<Long, ObTableParam>> buildPartitions(ObTableClient cl
376376
if (!client.isOdpMode()) {
377377
indexTableName = client.getIndexTableName(tableName, indexName, tableQuery.getScanRangeColumns(), false);
378378
}
379-
380379
for (ObNewRange range : tableQuery.getKeyRanges()) {
381380
ObRowKey startKey = range.getStartKey();
382381
int startKeySize = startKey.getObjs().size();
@@ -576,7 +575,8 @@ public void init() throws Exception {
576575
RUNTIME.error("Fail to get refresh table entry response after {}",
577576
retryTimes);
578577
throw new ObTableRetryExhaustedException(
579-
"Fail to get refresh table entry response after " + retryTimes);
578+
"Fail to get refresh table entry response after " + retryTimes +
579+
"errorCode:" + ((ObTableNeedFetchAllException) e).getErrorCode());
580580

581581
}
582582
} else {

src/main/java/com/alipay/oceanbase/rpc/stream/ObTableClientQueryAsyncStreamResult.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,8 @@ public void init() throws Exception {
8888
RUNTIME.error("Fail to get refresh table entry response after {}",
8989
retryTimes);
9090
throw new ObTableRetryExhaustedException(
91-
"Fail to get refresh table entry response after " + retryTimes);
91+
"Fail to get refresh table entry response after " + retryTimes
92+
+ "errorCode:" + ((ObTableNeedFetchAllException) e).getErrorCode());
9293

9394
}
9495
} else {

src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientQueryImpl.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -244,12 +244,10 @@ ObTableClientQueryAsyncStreamResult execute() throws Exception {
244244
public Map<Long, ObPair<Long, ObTableParam>> initPartitions(ObTableQuery tableQuery, String tableName) throws Exception {
245245
Map<Long, ObPair<Long, ObTableParam>> partitionObTables = new LinkedHashMap<>();
246246
String indexName = tableQuery.getIndexName();
247-
String indexTableName = null;
248247

249248
if (!this.obTableClient.isOdpMode()) {
250249
indexTableName = obTableClient.getIndexTableName(tableName, indexName, tableQuery.getScanRangeColumns(), false);
251250
}
252-
253251
for (ObNewRange range : tableQuery.getKeyRanges()) {
254252
ObRowKey startKey = range.getStartKey();
255253
int startKeySize = startKey.getObjs().size();

0 commit comments

Comments
 (0)