flink1.9.1单任务配置rocksDB不生效

Tue, 15 Dec 2020 01:05:39 -0800 

Hi，想请教大家一个问题，我用单任务配置使用rocksDB状态后端，代码如下：

    val backend = new RocksDBStateBackend(path, true)
    backend.setPredefinedOptions(PredefinedOptions.SPINNING_DISK_OPTIMIZED)
    env.setStateBackend(backend.asInstanceOf[StateBackend])

但是运行代码后，去webui查看Job Manager --> Configuration
中查看，发现state.backend还是显示filesystem

这是说明我的配置没有生效嘛？如果没有生效，那么如何进行单任务配置rocksDB呢？



-----
Best Wishes
--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复