How to use RockDb in pyflink(version 1.14.4)

["harshit.varshney@iktara.ai" <Ha...@iktara.ai>]

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

 

 

Re: How to use RockDb in pyflink(version 1.14.4)

[Dian Fu <di...@gmail.com>]

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.varshney@iktara.ai <
Harshit.Varshney@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
>
>
>
>
>