Skip to content

Commit 4961057

Browse files
authored
Fix compatibility issues with legacy ODP versions (#324)
1 parent e521b1b commit 4961057

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

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

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -433,10 +433,15 @@ private void initMetadata() throws Exception {
433433

434434
if (odpMode) {
435435
try {
436-
ObTableClientType clientType = runningMode == RunningMode.HBASE ? ObTableClientType.JAVA_HBASE_CLIENT : ObTableClientType.JAVA_TABLE_CLIENT;
437436
odpTable = new ObTable.Builder(odpAddr, odpPort) //
438-
.setLoginInfo(tenantName, fullUserName, password, database, clientType) //
437+
.setLoginInfo(tenantName, fullUserName, password, database, ObTableClientType.JAVA_TABLE_CLIENT) //
439438
.setProperties(getProperties()).setConfigs(TableConfigs).build();
439+
// Observer version has been obtained at this point
440+
if (ObGlobal.isDistributedExecSupport() && runningMode == RunningMode.HBASE) { // support distributed execute, login again
441+
odpTable = new ObTable.Builder(odpAddr, odpPort) //
442+
.setLoginInfo(tenantName, fullUserName, password, database, ObTableClientType.JAVA_HBASE_CLIENT) //
443+
.setProperties(getProperties()).setConfigs(TableConfigs).build();
444+
}
440445
} catch (Exception e) {
441446
logger
442447
.warn(

0 commit comments

Comments
 (0)