You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by chanamper <ch...@163.com> on 2020/01/14 14:32:55 UTC

关于使用Flink RocksDBStateBackend问题

Hi
在使用RocksDBStateBackend过程中，有些问题想请教一下
采用自定义的optionsFactory后，flink-conf.yaml配置文件中的RocksDB Configurable Options相关参数配置不生效，请问一下要如何使其中的state.backend.rocksdb.writebuffer.size等参数生效？

OptionsFactory optionsFactory = new OptionsFactory() {

    @Override

    public DBOptions createDBOptions(DBOptions dbOptions) {

     return (new DBOptions()).setUseFsync(false);

    }




    @Override

    public ColumnFamilyOptions createColumnOptions(ColumnFamilyOptions columnFamilyOptions) {

     return (new ColumnFamilyOptions()).setCompressionType(CompressionType.NO_COMPRESSION);

    }

   };

   RocksDBStateBackend rocksDBStateBackend = new RocksDBStateBackend("hdfs://:/flink/checkpoints");

   rocksDBStateBackend.setOptions(optionsFactory);

   env.setStateBackend(rocksDBStateBackend);

Re: 关于使用Flink RocksDBStateBackend问题

Posted by Yun Tang <my...@live.com>.
Hi

使用自定义options factory的话，我们会认为是高级用户，自然也就完全交由用户进行配置，至于write buffer size如何配置，可以参考PredefinedOptions [1] 的使用方法。

[1] https://github.com/apache/flink/blob/8f67d1d7e6809d528fe957cb4eb78308d87da324/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java#L173

祝好
唐云

________________________________
From: chanamper <ch...@163.com>
Sent: Tuesday, January 14, 2020 22:32
To: user-zh <us...@flink.apache.org>
Subject: 关于使用Flink RocksDBStateBackend问题

Hi
在使用RocksDBStateBackend过程中，有些问题想请教一下
采用自定义的optionsFactory后，flink-conf.yaml配置文件中的RocksDB Configurable Options相关参数配置不生效，请问一下要如何使其中的state.backend.rocksdb.writebuffer.size等参数生效？

OptionsFactory optionsFactory = new OptionsFactory() {

    @Override

    public DBOptions createDBOptions(DBOptions dbOptions) {

     return (new DBOptions()).setUseFsync(false);

    }




    @Override

    public ColumnFamilyOptions createColumnOptions(ColumnFamilyOptions columnFamilyOptions) {

     return (new ColumnFamilyOptions()).setCompressionType(CompressionType.NO_COMPRESSION);

    }

   };

   RocksDBStateBackend rocksDBStateBackend = new RocksDBStateBackend("hdfs://:/flink/checkpoints");

   rocksDBStateBackend.setOptions(optionsFactory);

   env.setStateBackend(rocksDBStateBackend);