I'm trying to bootstrap state into a KeyedProcessFunction equivalent that takes in a DataStream but I'm unable to find a reference for the same. I found this gist https://gist.github.com/alpinegizmo/ff3d2e748287853c88f21259830b29cf But it seems to only apply for DataSet. My usecase is to manually trigger a Savepoint into s3 for later reuse. I'm also guessing that checkpoints can't be stored in rocksdb or s3 for later reuse.
- Savepoints with bootstraping a datastream function Rakshit Ramesh
- Re: Savepoints with bootstraping a datastream function Arvid Heise
- Re: Savepoints with bootstraping a datastream func... Rakshit Ramesh
- Re: Savepoints with bootstraping a datastream ... Arvid Heise
- Re: Savepoints with bootstraping a datastr... Rakshit Ramesh
- Re: Savepoints with bootstraping a da... Arvid Heise
- Re: Savepoints with bootstraping ... Rakshit Ramesh
- Re: Savepoints with bootstrap... Rakshit Ramesh
- Re: Savepoints with bootstrap... Arvid Heise
- Re: Savepoints with bootstrap... Rakshit Ramesh
- Re: Savepoints with bootstrap... Rakshit Ramesh