Skip to content

Commit 4f5f373

Browse files
committed
fix: correct reverse-scan results affected by retry logic
1 parent 61ea5d2 commit 4f5f373

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -375,7 +375,7 @@ public boolean next() throws Exception {
375375
}
376376

377377
protected Map<Long, ObPair<Long, ObTableParam>> buildPartitions(ObTableClient client, ObTableQuery tableQuery, String tableName) throws Exception {
378-
Map<Long, ObPair<Long, ObTableParam>> partitionObTables = new HashMap<>();
378+
Map<Long, ObPair<Long, ObTableParam>> partitionObTables = new LinkedHashMap<>();
379379
String indexName = tableQuery.getIndexName();
380380
String indexTableName = null;
381381

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -235,7 +235,7 @@ ObTableClientQueryAsyncStreamResult execute() throws Exception {
235235
}
236236

237237
public Map<Long, ObPair<Long, ObTableParam>> initPartitions(ObTableQuery tableQuery, String tableName) throws Exception {
238-
Map<Long, ObPair<Long, ObTableParam>> partitionObTables = new HashMap<>();
238+
Map<Long, ObPair<Long, ObTableParam>> partitionObTables = new LinkedHashMap<>();
239239
String indexName = tableQuery.getIndexName();
240240
String indexTableName = null;
241241

0 commit comments

Comments
 (0)