谢谢 Yun Tang 大佬的解答~
另外,还想请教一下:我在代码中设置开启了cur-size-all-mem-tables的监控,代码如下:
//设置RocksDB状态后端,且开启增量ck
val backend = new RocksDBStateBackend(path, true)
//监控配置项
val metricOptions = new RocksDBNativeMetricOptions
metricOptions.enableSizeAllMemTables()
//设置预选项
backend.setPredefinedOptions(PredefinedOptions.SPINNING_DISK_OPTIMIZED)
//开启RocksDB
env.setStateBackend(backend.asInstanceOf[StateBackend])
但是发现这个监控指标并没有成功发送,请问是我在代码里开启的方式不对么?
-----
Best Wishes
--
Sent from: http://apache-flink.147419.n8.nabble.com/