Skip to content

Commit cba681a

Browse files
committed
fix getAllPartitionInternal
1 parent 12a4582 commit cba681a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3208,11 +3208,11 @@ private List<Partition> getAllPartitionInternal(String tableName, boolean refres
32083208
if (refresh) {
32093209
// List<ObPair<logic partId, obTableParam>>
32103210
allTables = getTables(tableName, new ObTableQuery(), new Object[]{ ObObj.getMin() }, true,
3211-
new Object[]{ ObObj.getMax() }, true, true, true, true, getRoute(false));
3211+
new Object[]{ ObObj.getMax() }, true, true, true, getRoute(false));
32123212
} else {
32133213
// List<ObPair<logic partId, obTableParam>>
32143214
allTables = getTables(tableName, new ObTableQuery(), new Object[]{ ObObj.getMin() }, true,
3215-
new Object[]{ ObObj.getMax() }, true, false, false, false, getRoute(false));
3215+
new Object[]{ ObObj.getMax() }, true, false, false, getRoute(false));
32163216
}
32173217
for (ObPair<Long, ObTableParam> table : allTables) {
32183218
ObTableParam tableParam = table.getRight();

0 commit comments

Comments
 (0)