diff options
| author | Hari Shreedharan <hshreedharan@apache.org> | 2014-09-25 22:56:43 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-09-25 22:56:43 -0700 |
| commit | b235e013638685758885842dc3268e9800af3678 (patch) | |
| tree | 0810d346ef6d6e270cd0606ba6f845dbca072c63 /python/pyspark/worker.py | |
| parent | 86bce764983f2b14e1bd87fc3f4f938f7a217e1b (diff) | |
| download | spark-b235e013638685758885842dc3268e9800af3678.tar.gz spark-b235e013638685758885842dc3268e9800af3678.tar.bz2 spark-b235e013638685758885842dc3268e9800af3678.zip | |
[SPARK-3686][STREAMING] Wait for sink to commit the channel before check...
...ing for the channel size.
Author: Hari Shreedharan <hshreedharan@apache.org>
Closes #2531 from harishreedharan/sparksinksuite-fix and squashes the following commits:
30393c1 [Hari Shreedharan] Use more deterministic method to figure out when batches come in.
6ce9d8b [Hari Shreedharan] [SPARK-3686][STREAMING] Wait for sink to commit the channel before checking for the channel size.
Diffstat (limited to 'python/pyspark/worker.py')
0 files changed, 0 insertions, 0 deletions