File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
src/main/java/com/alipay/oceanbase/hbase/util Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 2525import java .util .Properties ;
2626
2727import static com .alipay .oceanbase .hbase .constants .OHConstants .*;
28+ import static com .alipay .oceanbase .rpc .property .Property .RPC_CONNECT_TIMEOUT ;
2829import static org .apache .hadoop .hbase .client .ConnectionConfiguration .WRITE_BUFFER_PERIODIC_FLUSH_TIMEOUT_MS ;
2930import static org .apache .hadoop .hbase .client .ConnectionConfiguration .WRITE_BUFFER_PERIODIC_FLUSH_TIMEOUT_MS_DEFAULT ;
3031import static org .apache .hadoop .hbase .client .ConnectionConfiguration .WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS ;
@@ -99,8 +100,7 @@ public OHConnectionConfiguration(Configuration conf) {
99100 if (conf .get (SOCKET_TIMEOUT ) != null ) {
100101 rpcConnectTimeout = conf .getInt (SOCKET_TIMEOUT , DEFAULT_SOCKET_TIMEOUT );
101102 } else {
102- rpcConnectTimeout = conf .getInt (SOCKET_TIMEOUT_CONNECT ,
103- DEFAULT_SOCKET_TIMEOUT_CONNECT );
103+ rpcConnectTimeout = RPC_CONNECT_TIMEOUT .getDefaultInt (); // use table default value
104104 }
105105 }
106106 this .rpcConnectTimeout = rpcConnectTimeout ;
You can’t perform that action at this time.
0 commit comments