fix msg

apache · Oct 1, 2016 · ca45217 · ca45217
1 parent c71a03e
commit ca45217
Showing 1 changed file with 2 additions and 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
@@ -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"
   }
 }