flink1.9.1单任务配置rocksDB不生效

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

flink1.9.1单任务配置rocksDB不生效

bradyMk
CONTENTS DELETED
The author has deleted this message.
Reply | Threaded
Open this post in threaded view
|

Re: flink1.9.1单任务配置rocksDB不生效

Congxian Qiu
Hi
   state.backend 应该是你在 flink-conf 中设置了这个值。具体到你这里的情况,最终的配置是
RocksDB(以代码为准,如果代码没有设置会使用 flink-conf 中的文件)。你可以看看 TM 日志,应该可以看到更详细的信息
Best,
Congxian


bradyMk <[hidden email]> 于2020年12月15日周二 下午5:05写道:

> Hi,想请教大家一个问题,我用单任务配置使用rocksDB状态后端,代码如下:
>
>     val backend = new RocksDBStateBackend(path, true)
>     backend.setPredefinedOptions(PredefinedOptions.SPINNING_DISK_OPTIMIZED)
>     env.setStateBackend(backend.asInstanceOf[StateBackend])
>
> 但是运行代码后,去webui查看Job Manager --> Configuration
> 中查看,发现state.backend还是显示filesystem
>
> 这是说明我的配置没有生效嘛?如果没有生效,那么如何进行单任务配置rocksDB呢?
>
>
>
> -----
> Best Wishes
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>
Reply | Threaded
Open this post in threaded view
|

Re: flink1.9.1单任务配置rocksDB不生效

bradyMk
CONTENTS DELETED
The author has deleted this message.