Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/19984#discussion_r158117033
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala
---
@@ -303,7 +299,7 @@ abstract class StreamExecution(
e,
committedOffsets.toOffsetSeq(sources,
offsetSeqMetadata).toString,
availableOffsets.toOffsetSeq(sources,
offsetSeqMetadata).toString)
- logError(s"Query $prettyIdString terminated with error", e)
+ // logError(s"Query $prettyIdString terminated with error", e)
--- End diff --
nit: restore `logError`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
