Hi,

We use RocksDB with FsStateBackend (HDFS) to store state used by the
mapWithState operator. Is it possible to initialize / populate this state
during the streaming application startup?

Our intention is to reprocess the historical data from HDFS in a batch job
and save the latest state of the records onto HDFS. Thus when we restart
the streaming job we can just build up or load the most recent view of this
store.

Many thanks,
Peter

Reply via email to