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/

回复