You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/01/17 13:23:00 UTC
[jira] [Updated] (FLINK-11193) Rockdb timer service factory
configuration option is not settable
[ https://issues.apache.org/jira/browse/FLINK-11193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen updated FLINK-11193:
---------------------------------
Labels: pull-request-available usability (was: pull-request-available)
> Rockdb timer service factory configuration option is not settable
> -----------------------------------------------------------------
>
> 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: Major
> Labels: pull-request-available, usability
> Time Spent: 0.5h
> 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)