diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2014-04-24 21:34:37 -0700 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-04-24 21:34:37 -0700 |
commit | cd12dd9bde91303d0341180e5f70d2a03d6b65b6 (patch) | |
tree | 5e9d6510edaa1222e09355c239925cc7559c817d /sbin | |
parent | 968c0187a12f5ae4a696c02c1ff088e998ed7edd (diff) | |
download | spark-cd12dd9bde91303d0341180e5f70d2a03d6b65b6.tar.gz spark-cd12dd9bde91303d0341180e5f70d2a03d6b65b6.tar.bz2 spark-cd12dd9bde91303d0341180e5f70d2a03d6b65b6.zip |
[SPARK-1617] and [SPARK-1618] Improvements to streaming ui and bug fix to socket receiver
1617: These changes expose the receiver state (active or inactive) and last error in the UI
1618: If the socket receiver cannot connect in the first attempt, it should try to restart after a delay. That was broken, as the thread that restarts (hence, stops) the receiver waited on Thread.join on itself!
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #540 from tdas/streaming-ui-fix and squashes the following commits:
e469434 [Tathagata Das] Merge remote-tracking branch 'apache-github/master' into streaming-ui-fix
dbddf75 [Tathagata Das] Style fix.
66df1a5 [Tathagata Das] Merge remote-tracking branch 'apache/master' into streaming-ui-fix
ad98bc9 [Tathagata Das] Refactored streaming listener to use ReceiverInfo.
d7f849c [Tathagata Das] Revert "Moved BatchInfo from streaming.scheduler to streaming.ui"
5c80919 [Tathagata Das] Moved BatchInfo from streaming.scheduler to streaming.ui
da244f6 [Tathagata Das] Fixed socket receiver as well as made receiver state and error visible in the streamign UI.
Diffstat (limited to 'sbin')
0 files changed, 0 insertions, 0 deletions