Anna Qin created BEAM-10789:
-------------------------------
Summary: Add support for checkpointing in Spark streaming
Key: BEAM-10789
URL: https://issues.apache.org/jira/browse/BEAM-10789
Project: Beam
Issue Type: Improvement
Components: runner-spark
Reporter: Anna Qin
Spark streaming (both portable and non-portable) currently uses queueStream to
create the initial DStream from a queue of RDDs. However, queueStream does not
support checkpointing.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
