hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ga...@apache.org
Subject [10/50] [abbrv] hive git commit: HIVE-10476 - Hive query should fail when it fails to initialize a session in SetSparkReducerParallelism [Spark Branch] (Chao, reviewed by Rui)
Date Fri, 05 Jun 2015 23:16:23 GMT
HIVE-10476 - Hive query should fail when it fails to initialize a session in SetSparkReducerParallelism
[Spark Branch] (Chao, 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/cee1183d
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/cee1183d
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/cee1183d

Branch: refs/heads/hbase-metastore
Commit: cee1183d3044c4fa0a7882c3499d59721f1b5492
Parents: 88dfd27
Author: Chao Sun <sunchao@apache.org>
Authored: Tue Apr 28 09:39:18 2015 -0700
Committer: Xuefu Zhang <xzhang@Cloudera.com>
Committed: Mon Jun 1 14:03:09 2015 -0700

----------------------------------------------------------------------
 .../hadoop/hive/ql/optimizer/spark/SetSparkReducerParallelism.java | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/cee1183d/ql/src/java/org/apache/hadoop/hive/ql/optimizer/spark/SetSparkReducerParallelism.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/spark/SetSparkReducerParallelism.java
b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/spark/SetSparkReducerParallelism.java
index dcfbc6b..f9ef474 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/spark/SetSparkReducerParallelism.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/spark/SetSparkReducerParallelism.java
@@ -115,6 +115,8 @@ public class SetSparkReducerParallelism implements NodeProcessor {
             sparkSession = SparkUtilities.getSparkSession(
               context.getConf(), sparkSessionManager);
             sparkMemoryAndCores = sparkSession.getMemoryAndCores();
+          } catch (HiveException e) {
+            throw new SemanticException("Failed to get a spark session: " + e);
           } catch (Exception e) {
             LOG.warn("Failed to get spark memory/core info", e);
           } finally {


Mime
View raw message