diff --git a/src/main/java/com/alipay/oceanbase/hbase/util/OHConnectionConfiguration.java b/src/main/java/com/alipay/oceanbase/hbase/util/OHConnectionConfiguration.java index f194eb35..d2474a11 100644 --- a/src/main/java/com/alipay/oceanbase/hbase/util/OHConnectionConfiguration.java +++ b/src/main/java/com/alipay/oceanbase/hbase/util/OHConnectionConfiguration.java @@ -25,6 +25,7 @@ import java.util.Properties; import static com.alipay.oceanbase.hbase.constants.OHConstants.*; +import static com.alipay.oceanbase.rpc.property.Property.RPC_CONNECT_TIMEOUT; import static org.apache.hadoop.hbase.client.ConnectionConfiguration.WRITE_BUFFER_PERIODIC_FLUSH_TIMEOUT_MS; import static org.apache.hadoop.hbase.client.ConnectionConfiguration.WRITE_BUFFER_PERIODIC_FLUSH_TIMEOUT_MS_DEFAULT; import static org.apache.hadoop.hbase.client.ConnectionConfiguration.WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS; @@ -99,8 +100,7 @@ public OHConnectionConfiguration(Configuration conf) { if (conf.get(SOCKET_TIMEOUT) != null) { rpcConnectTimeout = conf.getInt(SOCKET_TIMEOUT, DEFAULT_SOCKET_TIMEOUT); } else { - rpcConnectTimeout = conf.getInt(SOCKET_TIMEOUT_CONNECT, - DEFAULT_SOCKET_TIMEOUT_CONNECT); + rpcConnectTimeout = RPC_CONNECT_TIMEOUT.getDefaultInt(); // use table default value } } this.rpcConnectTimeout = rpcConnectTimeout;