diff options
| author | Liwei Lin <lwlin7@gmail.com> | 2017-01-18 10:52:47 -0800 |
|---|---|---|
| committer | Shixiong Zhu <shixiong@databricks.com> | 2017-01-18 10:52:47 -0800 |
| commit | 569e50680f97b1ed054337a39fe198769ef52d93 (patch) | |
| tree | d5567d057d83ae2f5641c5929101e777265e1b1c /streaming | |
| parent | c050c12274fba2ac4c4938c4724049a47fa59280 (diff) | |
| download | spark-569e50680f97b1ed054337a39fe198769ef52d93.tar.gz spark-569e50680f97b1ed054337a39fe198769ef52d93.tar.bz2 spark-569e50680f97b1ed054337a39fe198769ef52d93.zip | |
[SPARK-19168][STRUCTURED STREAMING] StateStore should be aborted upon error
## What changes were proposed in this pull request?
We should call `StateStore.abort()` when there should be any error before the store is committed.
## How was this patch tested?
Manually.
Author: Liwei Lin <lwlin7@gmail.com>
Closes #16547 from lw-lin/append-filter.
Diffstat (limited to 'streaming')
0 files changed, 0 insertions, 0 deletions