osdir.com


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

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