diff options
| author | tedyu <yuzhihong@gmail.com> | 2015-11-17 22:47:53 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-11-17 22:47:53 -0800 |
| commit | 446738e51fcda50cf2dc44123ff6bf12a1611dc0 (patch) | |
| tree | 8940cccf64649eedfc1834e20146d7b1761cec5c /mllib | |
| parent | 8fb775ba874dd0488667bf299a7b49760062dc00 (diff) | |
| download | spark-446738e51fcda50cf2dc44123ff6bf12a1611dc0.tar.gz spark-446738e51fcda50cf2dc44123ff6bf12a1611dc0.tar.bz2 spark-446738e51fcda50cf2dc44123ff6bf12a1611dc0.zip | |
[SPARK-11761] Prevent the call to StreamingContext#stop() in the listener bus's thread
See discussion toward the tail of https://github.com/apache/spark/pull/9723
From zsxwing :
```
The user should not call stop or other long-time work in a listener since it will block the listener thread, and prevent from stopping SparkContext/StreamingContext.
I cannot see an approach since we need to stop the listener bus's thread before stopping SparkContext/StreamingContext totally.
```
Proposed solution is to prevent the call to StreamingContext#stop() in the listener bus's thread.
Author: tedyu <yuzhihong@gmail.com>
Closes #9741 from tedyu/master.
Diffstat (limited to 'mllib')
0 files changed, 0 insertions, 0 deletions