Github user zsxwing commented on a diff in the pull request: https://github.com/apache/spark/pull/21222#discussion_r206342173 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/execution/debug/package.scala --- @@ -116,6 +177,30 @@ package object debug { } } + implicit class DebugStreamQuery(query: StreamingQuery) extends Logging { + def debug(): Unit = { + try { + val w = asStreamExecution(query) + if (w.lastExecution == null) { + debugPrint("No physical plan. Waiting for data.") + } else { + val executedPlan = w.lastExecution.executedPlan + if (executedPlan.find(_.isInstanceOf[WriteToContinuousDataSourceExec]).isDefined) { + debugPrint("Debug on continuous mode is not supported.") + } else { + debugInternal(executedPlan) + } + } + } catch { --- End diff -- I prefer to remove this. There is nothing to do in this case. This basically means a bug in Spark: a new type is added but `asStreamExecution` is not updated accordingly.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org