Hi Harshit, Yes, this should be supported.
Have you tried the following doc [1] for Table API and [2] for DataStream API? Regards, Dian [1] https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/python/table/table_environment/#statebackend-checkpoint-and-restart-strategy [2] https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/datastream/fault-tolerance/checkpointing/#selecting-checkpoint-storage On Wed, Jun 22, 2022 at 7:46 PM harshit.varsh...@iktara.ai < harshit.varsh...@iktara.ai> wrote: > Dear Team, > > I request for your support in issue I am facing with Pyflink. I am using > Pyflink version 1.14.4. > > > > I want to use RockDb for checkpointing in stateful operation but it only > make a directory of checkpoint but there is no data is there like I do in > HashMap backend . Is Rockdb is supported in pyflink or not .If it is > supported please give me suggestion on how to use Rockdb with pyflink . > > > > Thanks and Regards, > > Harshit > > > > >
