Re: flink1.9.1 如何配置RocksDB的block-cache-usage参数

Thu, 17 Dec 2020 05:13:21 -0800 

Hi

这些metrics启用的配置是放到flink conf里面的，不是让你直接在代码里面调用的。

祝好
唐云
________________________________
From: bradyMk <[email protected]>
Sent: Thursday, December 17, 2020 20:56
To: [email protected] <[email protected]>
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/

回复