关于使用Flink RocksDBStateBackend问题

Tue, 14 Jan 2020 06:34:09 -0800 

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);

回复