diff --git spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java index 657494a..8f672e6 100644 --- spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java +++ spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java @@ -159,7 +159,7 @@ private ChannelFuture bindServerPort(ServerBootstrap serverBootstrap) */ public Future registerClient(final String clientId, String secret, RpcDispatcher serverDispatcher) { - return registerClient(clientId, secret, serverDispatcher, config.getServerConnectTimeoutMs()); + return registerClient(clientId, secret, serverDispatcher, config.getConnectTimeoutMs()); } @VisibleForTesting