diff --git a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java index d6b1711f..5da49bbc 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java +++ b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java @@ -360,7 +360,7 @@ public boolean next() throws Exception { } protected Map> buildPartitions(ObTableClient client, ObTableQuery tableQuery, String tableName) throws Exception { - Map> partitionObTables = new HashMap<>(); + Map> partitionObTables = new LinkedHashMap<>(); String indexName = tableQuery.getIndexName(); String indexTableName = null; diff --git a/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientQueryImpl.java b/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientQueryImpl.java index 46cf35a8..7ff2a8c9 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientQueryImpl.java +++ b/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientQueryImpl.java @@ -242,7 +242,7 @@ ObTableClientQueryAsyncStreamResult execute() throws Exception { } public Map> initPartitions(ObTableQuery tableQuery, String tableName) throws Exception { - Map> partitionObTables = new HashMap<>(); + Map> partitionObTables = new LinkedHashMap<>(); String indexName = tableQuery.getIndexName(); String indexTableName = null;