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..05eff2a 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 @@ -116,7 +116,7 @@ public Object process(Node nd, Stack stack, context.getConf(), sparkSessionManager); sparkMemoryAndCores = sparkSession.getMemoryAndCores(); } catch (Exception e) { - LOG.warn("Failed to get spark memory/core info", e); + throw new SemanticException("Failed to get spark memory/core info: " + e); } finally { if (sparkSession != null && sparkSessionManager != null) { try {