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)