diff --git spark-client/src/main/java/org/apache/hive/spark/client/rpc/Rpc.java spark-client/src/main/java/org/apache/hive/spark/client/rpc/Rpc.java index b2f133b..0489684 100644 --- spark-client/src/main/java/org/apache/hive/spark/client/rpc/Rpc.java +++ spark-client/src/main/java/org/apache/hive/spark/client/rpc/Rpc.java @@ -120,7 +120,7 @@ public void run() { } }; final ScheduledFuture timeoutFuture = eloop.schedule(timeoutTask, - rpcConf.getServerConnectTimeoutMs(), TimeUnit.MILLISECONDS); + connectTimeoutMs, TimeUnit.MILLISECONDS); // The channel listener instantiates the Rpc instance when the connection is established, // and initiates the SASL handshake.