diff options
| author | Ilayaperumal Gopinathan <igopinathan@pivotal.io> | 2015-01-20 01:41:10 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-01-20 01:41:10 -0800 |
| commit | 4afad9c7702239f6d5b1b49dc48ee08580964e17 (patch) | |
| tree | 2542333741008c30732b55a0f0503785f617237b /core | |
| parent | debc03195302789b022e329ce6ade5d7fe225a3c (diff) | |
| download | spark-4afad9c7702239f6d5b1b49dc48ee08580964e17.tar.gz spark-4afad9c7702239f6d5b1b49dc48ee08580964e17.tar.bz2 spark-4afad9c7702239f6d5b1b49dc48ee08580964e17.zip | |
[SPARK-4803] [streaming] Remove duplicate RegisterReceiver message
- The ReceiverTracker receivers `RegisterReceiver` messages two times
1) When the actor at `ReceiverSupervisorImpl`'s preStart is invoked
2) After the receiver is started at the executor `onReceiverStart()` at `ReceiverSupervisorImpl`
Though, RegisterReceiver message uses the same streamId and the receiverInfo gets updated everytime
the message is processed at the `ReceiverTracker`, it makes sense to call register receiver only after the
receiver is started.
Author: Ilayaperumal Gopinathan <igopinathan@pivotal.io>
Closes #3648 from ilayaperumalg/RTActor-remove-prestart and squashes the following commits:
868efab [Ilayaperumal Gopinathan] Increase receiverInfo collector timeout to 2 secs
3118e5e [Ilayaperumal Gopinathan] Fix StreamingListenerSuite's startedReceiverStreamIds size
634abde [Ilayaperumal Gopinathan] Remove duplicate RegisterReceiver message
Diffstat (limited to 'core')
0 files changed, 0 insertions, 0 deletions