Skip to content

Commit 82bcbe9

Browse files
committed
fix for compile
1 parent 3c6774c commit 82bcbe9

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1390,7 +1390,8 @@ public TableEntry refreshTableLocationByTabletId(TableEntry tableEntry, String t
13901390
tableEntryAcquireSocketTimeout,
13911391
serverAddressPriorityTimeout,
13921392
serverAddressCachingTimeout,
1393-
sysUA
1393+
sysUA,
1394+
!getServerCapacity().isSupportDistributedExecute() /* withLsId */
13941395
);
13951396

13961397
tableEntry.prepareForWeakRead(serverRoster.getServerLdcLocation());
@@ -4245,7 +4246,7 @@ public ObServerRoute getRoute(boolean readonly) {
42454246
}
42464247
}
42474248

4248-
private ObTableServerCapacity getServerCapacity() {
4249+
public ObTableServerCapacity getServerCapacity() {
42494250
if (tableRoster.isEmpty()) {
42504251
throw new IllegalStateException("client is not initialized and obTable is empty");
42514252
}

0 commit comments

Comments
 (0)