How can I programmatically set RocksDBStateBackend?

[kant kodali]

Hi All,

How can I programmatically set RocksDBStateBackend? I did the following

env.setStateBackend always shows deprecated. so what is the right way to do this in flink 1.10?

Thanks!

[KristoffSC]

Hi,
I had same case but with FsStateBackend.

Cast it to StateBackend type.
env.setStateBackend((StateBackend) new FsStateBackend("some/Path"));


I think this is some inconsistency in API.



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/