Skip to content

Commit 3640c86

Browse files
committed
Remove receiverInfo once receiver is de-registered
Once the streaming receiver is de-registered at executor, the `ReceiverTrackerActor` needs to remove the corresponding reveiverInfo from the `receiverInfo` map at `ReceiverTracker`.
1 parent 912563a commit 3640c86

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -152,6 +152,7 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false
152152
}
153153
receiverInfo(streamId) = newReceiverInfo
154154
listenerBus.post(StreamingListenerReceiverStopped(receiverInfo(streamId)))
155+
receiverInfo.remove(streamId)
155156
val messageWithError = if (error != null && !error.isEmpty) {
156157
s"$message - $error"
157158
} else {

0 commit comments

Comments
 (0)