diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/spark/RemoteHiveSparkClient.java ql/src/java/org/apache/hadoop/hive/ql/exec/spark/RemoteHiveSparkClient.java index c63335f..e1946d5 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/spark/RemoteHiveSparkClient.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/spark/RemoteHiveSparkClient.java @@ -24,6 +24,7 @@ import java.util.List; import java.util.Map; import java.util.concurrent.Future; +import java.util.concurrent.TimeUnit; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; @@ -88,7 +89,7 @@ public SparkConf getSparkConf() { @Override public int getExecutorCount() throws Exception { Future handler = remoteClient.getExecutorCount(); - return handler.get().intValue(); + return handler.get(5, TimeUnit.SECONDS).intValue(); } @Override