Create Savepoint with EmbeddedRocksDBStateBackend

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Create Savepoint with EmbeddedRocksDBStateBackend

jinxw
Hi everyone,

I'm trying to create a savepoint using this example
https://gist.github.com/alpinegizmo/ff3d2e748287853c88f21259830b29cf

But instead of

.create(new FsStateBackend("file:///tmp/checkpoints"), 256)

I need RocksDBStateBackend, since in 1.13.1 RocksDBStateBackend is deprecated, I have to use EmbeddedRocksDBStateBackend. But

.create(new EmbeddedRocksDBStateBackend(), 256)
 
doesn't work. What should I do?