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 /external/zeromq | |
| 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 'external/zeromq')
0 files changed, 0 insertions, 0 deletions