aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorSean Owen <sowen@cloudera.com>2016-11-16 10:16:36 +0000
committerSean Owen <sowen@cloudera.com>2016-11-16 10:16:36 +0000
commit43a26899e5dd2364297eaf8985bd68367e4735a7 (patch)
tree7d6ebf44636fd8daf6ff0ecce8c15f9938c3213d /examples
parent3e01f128284993f39463c0ccd902b774f57cce76 (diff)
downloadspark-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