Hi
state.backend 应该是你在 flink-conf 中设置了这个值。具体到你这里的情况,最终的配置是
RocksDB(以代码为准,如果代码没有设置会使用 flink-conf 中的文件)。你可以看看 TM 日志,应该可以看到更详细的信息
Best,
Congxian
bradyMk <
[hidden email]> 于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/>