diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2014-07-24 15:59:09 -0700 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-07-24 16:00:49 -0700 |
commit | 53b4e0f95750f371db14f8da4b5c4a1c38301710 (patch) | |
tree | 2bfc28ac6024c3c8e5310aeba4393033f0084d86 /yarn/common | |
parent | 91241592a4e8eb6ca9e0c7ff81b1eb1d100377aa (diff) | |
download | spark-53b4e0f95750f371db14f8da4b5c4a1c38301710.tar.gz spark-53b4e0f95750f371db14f8da4b5c4a1c38301710.tar.bz2 spark-53b4e0f95750f371db14f8da4b5c4a1c38301710.zip |
[SPARK-2464][Streaming] Fixed Twitter stream stopping bug
Stopping the Twitter Receiver would call twitter4j's TwitterStream.shutdown, which in turn causes an Exception to be thrown to the listener. This exception caused the Receiver to be restarted. This patch check whether the receiver was stopped or not, and accordingly restarts on exception.
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #1577 from tdas/twitter-stop and squashes the following commits:
011b525 [Tathagata Das] Fixed Twitter stream stopping bug.
(cherry picked from commit a45d5480f65d2e969fc7fbd8f358b1717fb99bef)
Signed-off-by: Tathagata Das <tathagata.das1565@gmail.com>
Diffstat (limited to 'yarn/common')
0 files changed, 0 insertions, 0 deletions