diff options
author | Sean Owen <sowen@cloudera.com> | 2016-11-16 10:16:36 +0000 |
---|---|---|
committer | Sean Owen <sowen@cloudera.com> | 2016-11-16 10:16:36 +0000 |
commit | 43a26899e5dd2364297eaf8985bd68367e4735a7 (patch) | |
tree | 7d6ebf44636fd8daf6ff0ecce8c15f9938c3213d /examples | |
parent | 3e01f128284993f39463c0ccd902b774f57cce76 (diff) | |
download | spark-43a26899e5dd2364297eaf8985bd68367e4735a7.tar.gz spark-43a26899e5dd2364297eaf8985bd68367e4735a7.tar.bz2 spark-43a26899e5dd2364297eaf8985bd68367e4735a7.zip |
[SPARK-18400][STREAMING] NPE when resharding Kinesis Stream
## What changes were proposed in this pull request?
Avoid NPE in KinesisRecordProcessor when shutdown happens without successful init
## How was this patch tested?
Existing tests
Author: Sean Owen <sowen@cloudera.com>
Closes #15882 from srowen/SPARK-18400.
Diffstat (limited to 'examples')
0 files changed, 0 insertions, 0 deletions