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/
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/