diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/spark/SetSparkReducerParallelism.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/spark/SetSparkReducerParallelism.java index dcfbc6b..f9ef474 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/spark/SetSparkReducerParallelism.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/spark/SetSparkReducerParallelism.java @@ -115,6 +115,8 @@ public Object process(Node nd, Stack stack, 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 {