Skip to content

Commit 2397312

Browse files
committed
fix ClientType Incompatible
1 parent f89dd6c commit 2397312

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

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

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4293,7 +4293,11 @@ public enum RunningMode {
42934293
}
42944294

42954295
private ObTableClientType getClientType(RunningMode runningMode) {
4296-
return runningMode == RunningMode.HBASE ? ObTableClientType.JAVA_HBASE_CLIENT : ObTableClientType.JAVA_TABLE_CLIENT;
4296+
if (ObGlobal.isDistributedExecSupport()) {
4297+
return runningMode == RunningMode.HBASE ? ObTableClientType.JAVA_HBASE_CLIENT : ObTableClientType.JAVA_TABLE_CLIENT;
4298+
} else {
4299+
return ObTableClientType.JAVA_TABLE_CLIENT;
4300+
}
42974301
}
42984302

42994303
/**

0 commit comments

Comments
 (0)