From ca4521770274168cf07c83ad62fdfefdaa36c14a Mon Sep 17 00:00:00 2001 From: gatorsmile Date: Fri, 30 Sep 2016 21:58:06 -0700 Subject: [PATCH] fix msg --- .../main/scala/org/apache/spark/sql/AnalysisException.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/AnalysisException.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/AnalysisException.scala index 6911843999392..6ca428239f5cc 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/AnalysisException.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/AnalysisException.scala @@ -45,6 +45,7 @@ class AnalysisException protected[sql] ( override def getMessage: String = { val lineAnnotation = line.map(l => s" line $l").getOrElse("") val positionAnnotation = startPosition.map(p => s" pos $p").getOrElse("") - s"$message;$lineAnnotation$positionAnnotation" + val planAnnotation = plan.map(p => s";\n$p").getOrElse("") + s"$message;$lineAnnotation$positionAnnotation$planAnnotation" } }