Hi 这些metrics启用的配置是放到flink conf里面的,不是让你直接在代码里面调用的。
祝好 唐云 ________________________________ From: bradyMk <zhbm...@126.com> Sent: Thursday, December 17, 2020 20:56 To: user-zh@flink.apache.org <user-zh@flink.apache.org> Subject: Re: flink1.9.1 如何配置RocksDB的block-cache-usage参数 谢谢 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/