Convert both exception message and stack trace to string

apache · Aug 17, 2016 · 60eabcc · 60eabcc
1 parent dafdbb6
commit 60eabcc
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
@@ -217,7 +217,7 @@ class StreamExecution(
     } finally {
       state = TERMINATED
       sparkSession.streams.notifyQueryTermination(StreamExecution.this)
-      postEvent(new QueryTerminated(this.toInfo, exception.map(_.getMessage)))
+      postEvent(new QueryTerminated(this.toInfo, exception.map(_.cause).map(Utils.exceptionString)))
       terminationLatch.countDown()
     }
   }

diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingQueryListenerSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingQueryListenerSuite.scala
@@ -161,7 +161,6 @@ class StreamingQueryListenerSuite extends StreamTest with BeforeAndAfter {
           // Make sure that the exception message reported through listener
           // contains the actual exception and relevant stack trace
           assert(!listener.terminationException.get.contains("StreamingQueryException"))
-          assert(listener.terminationException.get.contains("terminated with exception"))
           assert(listener.terminationException.get.contains("java.lang.ArithmeticException"))
           assert(listener.terminationException.get.contains("StreamingQueryListenerSuite"))
         }