Hi all, To recover (functionally) Accumulators from Driver failure in a streaming application, we wrap them in a "getOrCreate" Singleton as shown here <https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/streaming/RecoverableNetworkWordCount.scala#L123> . I was wondering how that works if I use the Accumulators inside a mapWithState/updateStateByKey operator ? Has anyone used Accumulators in one of the stateful operators ?
Thanks, Amit