Flink1.10.1代码自定义rocksdb backend webui中还是yaml显示默认的配置

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

Flink1.10.1代码自定义rocksdb backend webui中还是yaml显示默认的配置

Storm☀️
flink1.10.1
在代码中通过如下方式指定backend
streamEnv.setStateBackend(new
RocksDBStateBackend("hdfs:///user/flink/flink-checkpoints", false));

问题:flink web ui jm中显示的依然为yaml中默认配置
实际上面代码中的配置已经生效



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