Skip to content

Commit e5fa7d7

Browse files
committed
Add checkpoint location log
1 parent 22e02b9 commit e5fa7d7

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StreamExecution.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -218,6 +218,7 @@ class StreamExecution(
218218
* has been posted to all the listeners.
219219
*/
220220
def start(): Unit = {
221+
logInfo(s"Starting $prettyIdString. Use $checkpointRoot to store the query checkpoint.")
221222
microBatchThread.setDaemon(true)
222223
microBatchThread.start()
223224
startLatch.await() // Wait until thread started and QueryStart event has been posted

0 commit comments

Comments
 (0)