Skip to content

Commit 1eae5a4

Browse files
committed
fix global index route error
1 parent b15bcc7 commit 1eae5a4

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

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

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -393,8 +393,6 @@ public boolean next() throws Exception {
393393
protected Map<Long, ObPair<Long, ObTableParam>> buildPartitions(ObTableClient client, ObTableQuery tableQuery, String tableName) throws Exception {
394394
Map<Long, ObPair<Long, ObTableParam>> partitionObTables = new LinkedHashMap<>();
395395
String indexName = tableQuery.getIndexName();
396-
String indexTableName = null;
397-
398396
if (!client.isOdpMode()) {
399397
indexTableName = client.getIndexTableName(tableName, indexName, tableQuery.getScanRangeColumns(), false);
400398
}
@@ -446,12 +444,12 @@ protected void nextRow() {
446444

447445
protected void checkStatus() throws IllegalStateException {
448446
if (!initialized) {
449-
throw new IllegalStateException("table " + tableName
447+
throw new IllegalStateException("table " + indexTableName
450448
+ "query stream result is not initialized");
451449
}
452450

453451
if (closed) {
454-
throw new IllegalStateException("table " + tableName + " query stream result is closed");
452+
throw new IllegalStateException("table " + indexTableName + " query stream result is closed");
455453
}
456454
}
457455

0 commit comments

Comments
 (0)