Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/23095#discussion_r235473858
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/continuous/ContinuousExecution.scala
---
@@ -117,6 +117,7 @@ class ContinuousExecution(
// For at least once, we can just ignore those reports and risk
duplicates.
commitLog.getLatest() match {
case Some((latestEpochId, _)) =>
+ updateStatusMessage(s"Getting offsets from latest epoch
$latestEpochId")
--- End diff --
nit: I'd mention that we're restarting the streaming query from an existing
epoch in this message, to contrast with "starting new query" in the other branch
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
