Hi state.backend 应该是你在 flink-conf 中设置了这个值。具体到你这里的情况，最终的配置是 RocksDB（以代码为准，如果代码没有设置会使用 flink-conf 中的文件）。你可以看看 TM 日志，应该可以看到更详细的信息 Best, Congxian
bradyMk <[email protected]> 于2020年12月15日周二 下午5:05写道： > 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/ >
