diff options
| author | Shixiong Zhu <shixiong@databricks.com> | 2016-10-06 12:51:12 -0700 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2016-10-06 12:51:12 -0700 |
| commit | 9a48e60e6319d85f2c3be3a3c608dab135e18a73 (patch) | |
| tree | 2f6081f4b8a0eab9696d7816932bc286832fa4ae /python/pyspark/sql/readwriter.py | |
| parent | 79accf45ace5549caa0cbab02f94fc87bedb5587 (diff) | |
| download | spark-9a48e60e6319d85f2c3be3a3c608dab135e18a73.tar.gz spark-9a48e60e6319d85f2c3be3a3c608dab135e18a73.tar.bz2 spark-9a48e60e6319d85f2c3be3a3c608dab135e18a73.zip | |
[SPARK-17780][SQL] Report Throwable to user in StreamExecution
## What changes were proposed in this pull request?
When using an incompatible source for structured streaming, it may throw NoClassDefFoundError. It's better to just catch Throwable and report it to the user since the streaming thread is dying.
## How was this patch tested?
`test("NoClassDefFoundError from an incompatible source")`
Author: Shixiong Zhu <shixiong@databricks.com>
Closes #15352 from zsxwing/SPARK-17780.
Diffstat (limited to 'python/pyspark/sql/readwriter.py')
0 files changed, 0 insertions, 0 deletions