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 /assembly | |
| 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 'assembly')
0 files changed, 0 insertions, 0 deletions