Skip to content

Commit 6920d74

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 17107a8 commit 6920d74

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
@@ -158,7 +158,6 @@ protected ObPayload commonExecute(ObTableClient client, Logger logger,
158158
result = subObTable.executeWithConnection(request, connectionRef);
159159
} else {
160160
result = subObTable.execute(request);
161-
162161
if (result != null && result.getPcode() == Pcodes.OB_TABLE_API_MOVE) {
163162
ObTableApiMove moveResponse = (ObTableApiMove) result;
164163
client.getRouteTableRefresher().addTableIfAbsent(indexTableName, true);
@@ -594,7 +593,8 @@ public void init() throws Exception {
594593
RUNTIME.error("Fail to get refresh table entry response after {}",
595594
retryTimes);
596595
throw new ObTableRetryExhaustedException(
597-
"Fail to get refresh table entry response after " + retryTimes);
596+
"Fail to get refresh table entry response after " + retryTimes +
597+
"errorCode:" + ((ObTableNeedFetchAllException) e).getErrorCode());
598598

599599
}
600600
} 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
@@ -264,7 +264,6 @@ ObTableClientQueryAsyncStreamResult execute() throws Exception {
264264
public Map<Long, ObPair<Long, ObTableParam>> initPartitions(ObTableQuery tableQuery, String tableName) throws Exception {
265265
Map<Long, ObPair<Long, ObTableParam>> partitionObTables = new LinkedHashMap<>();
266266
String indexName = tableQuery.getIndexName();
267-
String indexTableName = null;
268267

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

0 commit comments

Comments
 (0)