Skip to content

Commit 84aeb90

Browse files
committed
fix
1 parent 6afeb69 commit 84aeb90

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/main/java/com/alipay/oceanbase/rpc/location/LocationUtil.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -920,7 +920,10 @@ public static TableEntry getTableEntryLocationFromRemote(Connection connection,
920920
ps.setString(1, key.getTenantName());
921921
ps.setString(2, key.getDatabaseName());
922922
ps.setString(3, key.getTableName());
923-
ps.setString(4, key.getTenantName());
923+
if (ObGlobal.obVsnMajor() >= 4) {
924+
// Only for v4.
925+
ps.setString(4, key.getTenantName());
926+
}
924927
rs = ps.executeQuery();
925928
partitionEntry = getPartitionLocationFromResultSet(tableEntry, rs, partitionEntry);
926929
} catch (Exception e) {

0 commit comments

Comments
 (0)