Skip to content

Commit 6eb97d5

Browse files
committed
Polishing based on the review
1 parent 3640c86 commit 6eb97d5

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -150,9 +150,8 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false
150150
logWarning("No prior receiver info")
151151
ReceiverInfo(streamId, "", null, false, "", lastErrorMessage = message, lastError = error)
152152
}
153-
receiverInfo(streamId) = newReceiverInfo
154-
listenerBus.post(StreamingListenerReceiverStopped(receiverInfo(streamId)))
155-
receiverInfo.remove(streamId)
153+
receiverInfo -= streamId
154+
listenerBus.post(StreamingListenerReceiverStopped(newReceiverInfo))
156155
val messageWithError = if (error != null && !error.isEmpty) {
157156
s"$message - $error"
158157
} else {

0 commit comments

Comments
 (0)