Github user CodingCat commented on a diff in the pull request:
https://github.com/apache/spark/pull/19926#discussion_r156458765
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala ---
@@ -285,12 +285,13 @@ trait StreamTest extends QueryTest with
SharedSQLContext with TimeLimits with Be
if (currentStream != null) currentStream.committedOffsets.toString
else "not started"
def threadState =
- if (currentStream != null && currentStream.microBatchThread.isAlive)
"alive" else "dead"
- def threadStackTrace = if (currentStream != null &&
currentStream.microBatchThread.isAlive) {
- s"Thread stack trace:
${currentStream.microBatchThread.getStackTrace.mkString("\n")}"
- } else {
- ""
- }
+ if (currentStream != null &&
currentStream.queryExecutionThread.isAlive) "alive" else "dead"
+ def threadStackTrace =
--- End diff --
we may want to add a new line above this
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
