You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Fan weiwen (JIRA)" <ji...@apache.org> on 2018/12/18 16:02:00 UTC

[jira] [Created] (FLINK-11193) rockdb customize configuration Covered jobmaster

Fan weiwen created FLINK-11193:
----------------------------------

             Summary: rockdb customize configuration Covered jobmaster
                 Key: FLINK-11193
                 URL: https://issues.apache.org/jira/browse/FLINK-11193
             Project: Flink
          Issue Type: Bug
          Components: State Backends, Checkpointing
    Affects Versions: 1.7.0, 1.6.2
            Reporter: Fan weiwen


set state backends is rocksdb 

set 'state.backend.rocksdb.timer-service.factory' by  Configuration
{code:java}
RocksDBStateBackend backend = new RocksDBStateBackend(checkpointPath,true);
Configuration configuration = new Configuration();
configuration.setString(
   RocksDBOptions.TIMER_SERVICE_FACTORY,
   RocksDBStateBackend.PriorityQueueStateType.ROCKSDB.toString());
backend = backend.configure(configuration);

{code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)