You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by li...@apache.org on 2017/06/16 08:02:35 UTC

hive git commit: HIVE-16910: RpcConfiguration - Improper Cast From Long To Int (BELUGA BEHR reviewed by Rui)

Repository: hive
Updated Branches:
  refs/heads/master c4382569d -> 8dfa8a5ae


HIVE-16910: RpcConfiguration - Improper Cast From Long To Int (BELUGA BEHR reviewed by Rui)


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

Branch: refs/heads/master
Commit: 8dfa8a5ae2a1d2b73aafc529dc42e89f76c026af
Parents: c438256
Author: BELUGA BEHR <da...@gmail.com>
Authored: Fri Jun 16 16:02:30 2017 +0800
Committer: Rui Li <li...@apache.org>
Committed: Fri Jun 16 16:02:30 2017 +0800

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


http://git-wip-us.apache.org/repos/asf/hive/blob/8dfa8a5a/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcConfiguration.java
----------------------------------------------------------------------
diff --git a/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcConfiguration.java b/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcConfiguration.java
index b6fd4f8..a535b8d 100644
--- a/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcConfiguration.java
+++ b/spark-client/src/main/java/org/apache/hive/spark/client/rpc/RpcConfiguration.java
@@ -73,7 +73,7 @@ public final class RpcConfiguration {
 
   long getConnectTimeoutMs() {
     String value = config.get(HiveConf.ConfVars.SPARK_RPC_CLIENT_CONNECT_TIMEOUT.varname);
-    return value != null ? Integer.parseInt(value) : DEFAULT_CONF.getTimeVar(
+    return value != null ? Long.parseLong(value) : DEFAULT_CONF.getTimeVar(
       HiveConf.ConfVars.SPARK_RPC_CLIENT_CONNECT_TIMEOUT, TimeUnit.MILLISECONDS);
   }