[FLINK-24314] Always use memory state backend with RocksDB

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.13.0, 1.13.2
• Component/s: Runtime / Web Frontend
• Assignee: Unassigned
• Reporter: shiwuliang
• Created: 17/Sep/21 03:00
• Updated: 17/Sep/21 09:54

Description

When I config to use `RocksDBStatebackend`, 

 

//代码占位符
RocksDBStateBackend rocksDBStateBackend = new RocksDBStateBackend("hdfs://xxxx");
streamEnv.setStateBackend(rocksDBStateBackend);

 

there are some exception like this:

 

Seems like the RocksdbStatebackend will use FsStateBackend to store checkpoints. So it means that I have used FileSystemStateBackend, why does this exception occur?

 

I use flink 1.13.0 and found a similar question like this at: https://stackoverflow.com/questions/68314652/flink-state-backend-config-with-the-state-processor-api

 

I'm not sure if his question is same with mine.

I want to know how can I solve this and if it is indeed a 1.13.0 bug, how can I bypass it besides upgrading?