Skip to content

Commit bec5329

Browse files
authored
Merge pull request #208 from oceanbase/fix-rescan-result-error
fix: correct reverse-scan results affected by retry logic
2 parents e5e8687 + c8e655a commit bec5329

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
@@ -360,7 +360,7 @@ public boolean next() throws Exception {
360360
}
361361

362362
protected Map<Long, ObPair<Long, ObTableParam>> buildPartitions(ObTableClient client, ObTableQuery tableQuery, String tableName) throws Exception {
363-
Map<Long, ObPair<Long, ObTableParam>> partitionObTables = new HashMap<>();
363+
Map<Long, ObPair<Long, ObTableParam>> partitionObTables = new LinkedHashMap<>();
364364
String indexName = tableQuery.getIndexName();
365365
String indexTableName = null;
366366

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

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

244244
public Map<Long, ObPair<Long, ObTableParam>> initPartitions(ObTableQuery tableQuery, String tableName) throws Exception {
245-
Map<Long, ObPair<Long, ObTableParam>> partitionObTables = new HashMap<>();
245+
Map<Long, ObPair<Long, ObTableParam>> partitionObTables = new LinkedHashMap<>();
246246
String indexName = tableQuery.getIndexName();
247247
String indexTableName = null;
248248

0 commit comments

Comments
 (0)