Skip to content

Commit 684a44e

Browse files
authored
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 dc0be4b commit 684a44e

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
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);
@@ -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 & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -244,7 +244,6 @@ 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);

0 commit comments

Comments
 (0)