spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dgoldenberg <>
Subject What happens when a streaming consumer job is killed then restarted?
Date Tue, 16 Jun 2015 23:06:38 GMT
I'd like to understand better what happens when a streaming consumer job
(with direct streaming, but also with receiver-based streaming) is

Assuming it was processing a batch of RDD data, what happens when the job is
restarted?  How much state is maintained within Spark's checkpointing to
allow for little or no data loss?

For the direct streaming case, would we need to update offsets in Zookeeper
to achieve more fault tolerance?

I'm looking at
and it talks about the Write-Ahead Logs. Do they work with direct streaming?

With write ahead logs in place, e.g. streaming from Kafka, where would a
restarted consumer resume processing?  E.g. it was processing Message# 25
out of 100 messages in the Kafka topic when it crashed or was terminated.


View this message in context:
Sent from the Apache Spark User List mailing list archive at

To unsubscribe, e-mail:
For additional commands, e-mail:

View raw message