diff options
author | zsxwing <zsxwing@gmail.com> | 2014-12-30 14:39:13 -0800 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-12-30 14:39:13 -0800 |
commit | 6a897829444e2ef273586511f93a40d36e64fb0b (patch) | |
tree | d48ba53b27c79f0abb7816aeb7682250521c7ebb /core | |
parent | 0f31992c61f6662e5347745f6a1ac272a5fd63c9 (diff) | |
download | spark-6a897829444e2ef273586511f93a40d36e64fb0b.tar.gz spark-6a897829444e2ef273586511f93a40d36e64fb0b.tar.bz2 spark-6a897829444e2ef273586511f93a40d36e64fb0b.zip |
[SPARK-4813][Streaming] Fix the issue that ContextWaiter didn't handle 'spurious wakeup'
Used `Condition` to rewrite `ContextWaiter` because it provides a convenient API `awaitNanos` for timeout.
Author: zsxwing <zsxwing@gmail.com>
Closes #3661 from zsxwing/SPARK-4813 and squashes the following commits:
52247f5 [zsxwing] Add explicit unit type
be42bcf [zsxwing] Update as per review suggestion
e06bd4f [zsxwing] Fix the issue that ContextWaiter didn't handle 'spurious wakeup'
Diffstat (limited to 'core')
0 files changed, 0 insertions, 0 deletions