Skip to content
Snippets Groups Projects
Commit 7ce3b818 authored by Tathagata Das's avatar Tathagata Das Committed by Andrew Or
Browse files

[MINOR] [STREAMING] Fix log statements in ReceiverSupervisorImpl

Log statements incorrectly showed that the executor was being stopped when receiver was being stopped.

Author: Tathagata Das <tathagata.das1565@gmail.com>

Closes #7328 from tdas/fix-log and squashes the following commits:

9cc6e99 [Tathagata Das] Fix log statements.
parent 0b0b9cea
No related branches found
No related tags found
No related merge requests found
......@@ -182,12 +182,12 @@ private[streaming] abstract class ReceiverSupervisor(
/** Wait the thread until the supervisor is stopped */
def awaitTermination() {
logInfo("Waiting for receiver to be stopped")
stopLatch.await()
logInfo("Waiting for executor stop is over")
if (stoppingError != null) {
logError("Stopped executor with error: " + stoppingError)
logError("Stopped receiver with error: " + stoppingError)
} else {
logWarning("Stopped executor without error")
logInfo("Stopped receiver without error")
}
if (stoppingError != null) {
throw stoppingError
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment