[
https://issues.apache.org/jira/browse/FLINK-11193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-11193:
----------------------------
Summary: Rocksdb timer service factory configuration option is not settable
per job (was: Rockdb timer service factory configuration option is not
settable per job)
> Rocksdb timer service factory configuration option is not settable per job
> --------------------------------------------------------------------------
>
> Key: FLINK-11193
> URL: https://issues.apache.org/jira/browse/FLINK-11193
> Project: Flink
> Issue Type: Bug
> Components: Runtime / State Backends
> Affects Versions: 1.6.2, 1.6.4, 1.7.0
> Reporter: Fan weiwen
> Assignee: Aitozi
> Priority: Minor
> Labels: pull-request-available, usability
> Fix For: 1.8.4, 1.9.3, 1.10.1, 1.11.0
>
> Time Spent: 40m
> Remaining Estimate: 0h
>
> 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}
> then submit the job by client
> but the job runtime the 'TIMER_SERVICE_FACTORY' Covered by jobmaster
> jobmaster code
> org.apache.flink.runtime.state.StateBackendLoader
> {code:java}
> backend = ((ConfigurableStateBackend) fromApplication).configure(config);
> {code}
> jobmaster buildGraph config is from flink-conf.yaml
> Final execution of the same method
> org.apache.flink.contrib.streaming.state.RocksDBStateBackend
> {code:java}
> final String priorityQueueTypeString =
> config.getString(TIMER_SERVICE_FACTORY);
> this.priorityQueueStateType = priorityQueueTypeString.length() > 0 ?
> PriorityQueueStateType.valueOf(priorityQueueTypeString.toUpperCase()) :
> original.priorityQueueStateType;
> {code}
> the problem is config.getString(TIMER_SERVICE_FACTORY) always have value
> regardless of configuration
> so my customize config is Covered by jobmaster
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
