File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
src/main/java/com/alipay/oceanbase/rpc/stream/async Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -52,7 +52,8 @@ public ObTableQueryAsyncClientResultSet(ObTableClientQueryAsyncImpl obTableClien
5252 public boolean next () throws Exception {
5353 boolean res = false ;
5454 // 对于分区/非分区表,从第一个分区0开始,在每个分区内都执行init和next;如此迭代每一个分区。直到isHasMore=false且分区都遍历完
55- if (cur < partitionIndex || resultSet .isHasMore () || partitionIndex == 0 ) {
55+ if (cur < partitionIndex || partitionIndex == 0 || resultSet == null
56+ || resultSet .isHasMore ()) {
5657 if (resultSet == null ) {
5758 resultSet = this .obTableClientQueryAsync .getTableQuery ()
5859 .executeInit (lists .get (cur ));
@@ -124,4 +125,4 @@ public void init() throws Exception {
124125 public void close () throws Exception {
125126 resultSet .getQueryStreamResult ().close ();
126127 }
127- }
128+ }
You can’t perform that action at this time.
0 commit comments