@@ -167,7 +167,8 @@ private AbstractQueryStreamResult commonExecute(InitQueryResultCallback<Abstract
167167 && !tableQuery .getIndexName ().equalsIgnoreCase ("primary" )) {
168168 throw new ObTableException ("key range columns must be specified when use index" );
169169 }
170- } else if (tableQuery .getIndexName () != null ) {
170+ }
171+ if (tableQuery .getIndexName () != null ) {
171172 this .partitionObTables .put (0L , new ObPair <Long , ObTableParam >(0L , new ObTableParam (
172173 obTableClient .getOdpTable ())));
173174 } else if (getPartId () == null ) {
@@ -288,9 +289,8 @@ public void initPartitions() throws Exception {
288289 // pairs -> List<Pair<logicId, param>>
289290 List <ObPair <Long , ObTableParam >> pairs = null ;
290291 if (!this .obTableClient .isOdpMode ()) {
291- pairs = this .obTableClient .getTables (indexTableName ,
292- tableQuery , start , borderFlag .isInclusiveStart (), end , borderFlag .isInclusiveEnd (),
293- false , false );
292+ pairs = this .obTableClient .getTables (indexTableName , tableQuery , start ,
293+ borderFlag .isInclusiveStart (), end , borderFlag .isInclusiveEnd (), false , false );
294294 } else {
295295 pairs = this .obTableClient .getOdpTables (tableName , tableQuery , start ,
296296 borderFlag .isInclusiveStart (), end , borderFlag .isInclusiveEnd (), false );
0 commit comments