You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ct...@apache.org on 2017/03/17 22:41:47 UTC

hive git commit: HIVE-16071: HoS RPCServer misuses the timeout in its RPC handshake (Chaoyu Tang, reviewed by Rui Li, Xuefu Zhang)

Repository: hive
Updated Branches:
  refs/heads/master 5ec298fd4 -> b7ecd6fbf


HIVE-16071: HoS RPCServer misuses the timeout in its RPC handshake (Chaoyu Tang, reviewed by Rui Li, Xuefu Zhang)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/b7ecd6fb
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/b7ecd6fb
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/b7ecd6fb

Branch: refs/heads/master
Commit: b7ecd6fbff3eda88d2b57bcc24f80978b4f5ce06
Parents: 5ec298f
Author: Chaoyu Tang <ct...@cloudera.com>
Authored: Fri Mar 17 18:40:53 2017 -0400
Committer: Chaoyu Tang <ct...@cloudera.com>
Committed: Fri Mar 17 18:40:53 2017 -0400

----------------------------------------------------------------------
 .../src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/b7ecd6fb/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java
----------------------------------------------------------------------
diff --git a/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java b/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java
index 657494a..08fb535 100644
--- a/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java
+++ b/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcServer.java
@@ -105,7 +105,7 @@ public class RpcServer implements Closeable {
                 }
             };
             saslHandler.cancelTask = group.schedule(cancelTask,
-                RpcServer.this.config.getServerConnectTimeoutMs(),
+                RpcServer.this.config.getConnectTimeoutMs(),
                 TimeUnit.MILLISECONDS);
 
           }