diff options
author | zsxwing <zsxwing@gmail.com> | 2015-06-30 11:14:38 -0700 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-06-30 11:14:38 -0700 |
commit | 57264400ac7d9f9c59c387c252a9ed8d93fed4fa (patch) | |
tree | 8f1e5d4351ec0bf5aa644a28c625de119398dad1 /docker | |
parent | ca7e460f7d6fb898dc29236a85520bbe954c8a13 (diff) | |
download | spark-57264400ac7d9f9c59c387c252a9ed8d93fed4fa.tar.gz spark-57264400ac7d9f9c59c387c252a9ed8d93fed4fa.tar.bz2 spark-57264400ac7d9f9c59c387c252a9ed8d93fed4fa.zip |
[SPARK-8630] [STREAMING] Prevent from checkpointing QueueInputDStream
This PR throws an exception in `QueueInputDStream.writeObject` so that it can fail the application when calling `StreamingContext.start` rather than failing it during recovering QueueInputDStream.
Author: zsxwing <zsxwing@gmail.com>
Closes #7016 from zsxwing/queueStream-checkpoint and squashes the following commits:
89a3d73 [zsxwing] Fix JavaAPISuite.testQueueStream
cc40fd7 [zsxwing] Prevent from checkpointing QueueInputDStream
Diffstat (limited to 'docker')
0 files changed, 0 insertions, 0 deletions