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)