Skip to content

Commit fff65c9

Browse files
GroundWumaochongxin
authored andcommitted
Fix global route refresh wrong (#231)
* fix global index route refresh wrong when route need refresh * fix global index route wrong * revert unused commit
1 parent a044ad8 commit fff65c9

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,6 @@ protected ObPayload commonExecute(ObTableClient client, Logger logger,
155155
result = subObTable.executeWithConnection(request, connectionRef);
156156
} else {
157157
result = subObTable.execute(request);
158-
159158
if (result != null && result.getPcode() == Pcodes.OB_TABLE_API_MOVE) {
160159
ObTableApiMove moveResponse = (ObTableApiMove) result;
161160
client.getRouteTableRefresher().addTableIfAbsent(indexTableName, true);
@@ -583,7 +582,8 @@ public void init() throws Exception {
583582
RUNTIME.error("Fail to get refresh table entry response after {}",
584583
retryTimes);
585584
throw new ObTableRetryExhaustedException(
586-
"Fail to get refresh table entry response after " + retryTimes);
585+
"Fail to get refresh table entry response after " + retryTimes +
586+
"errorCode:" + ((ObTableNeedFetchAllException) e).getErrorCode());
587587

588588
}
589589
} else {

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -237,7 +237,6 @@ ObTableClientQueryAsyncStreamResult execute() throws Exception {
237237
public Map<Long, ObPair<Long, ObTableParam>> initPartitions(ObTableQuery tableQuery, String tableName) throws Exception {
238238
Map<Long, ObPair<Long, ObTableParam>> partitionObTables = new LinkedHashMap<>();
239239
String indexName = tableQuery.getIndexName();
240-
String indexTableName = null;
241240

242241
if (!this.obTableClient.isOdpMode()) {
243242
indexTableName = obTableClient.getIndexTableName(tableName, indexName, tableQuery.getScanRangeColumns(), false);

0 commit comments

Comments
 (0)