MuthuLakshmi
Databricks Employee
Databricks Employee

@xhudik 
does stream.stop() generates "ERROR: Query termination received for []" automatically?
Yes, this is generated when there is stream.stop() in stdderIs

ERROR: Query termination received for [] dangerous, or it is just ans info stream was closed?
The "Query termination received" message that is not preceded by an Exception is not a concern, since this message is simply triggered by streamingContext.stop(), which stops the execution of streams after processing all incoming data. This is considered a graceful stop scenario and a behavior by design for logs.

View solution in original post