It does get recovered if you restart from checkpoints. See the example RecoverableNetworkWordCount.scala
On Sat, Jan 2, 2016 at 6:22 AM, Rado Buranský <radoburan...@gmail.com> wrote: > I am trying to understand how state in Spark Streaming works in general. > If I run this example program twice will the second run see state from the > first run? > > https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/streaming/StatefulNetworkWordCount.scala > > It seems no. Is there a way how to achieve this? I am thinking about > redeploying an application an I would like not to loose the current state. > > Thanks >
