You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Zhenqiu Huang (JIRA)" <ji...@apache.org> on 2019/03/15 13:00:00 UTC
[jira] [Commented] (FLINK-10912) Configurable RocksDBStateBackend
options factory
[ https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793600#comment-16793600 ]
Zhenqiu Huang commented on FLINK-10912:
---------------------------------------
Can this feature be used in Flink 1.6 release?
> Configurable RocksDBStateBackend options factory
> ------------------------------------------------
>
> Key: FLINK-10912
> URL: https://issues.apache.org/jira/browse/FLINK-10912
> Project: Flink
> Issue Type: New Feature
> Components: Runtime / State Backends
> Affects Versions: 1.7.0
> Reporter: Thomas Weise
> Assignee: Yun Tang
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.8.0
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> RocksDB has a ton of configuration options and users should be able to reach those, when necessary. Currently there are a few predefined configurations that can be activated programmatically [1] [2]. This requires change to the pipeline construction code that's hard or impossible when using higher level API or frameworks such as Apache Beam. It would be good to support an options factory that can be specified as part of the state backend configuration in flink-conf.yaml.
> [1] https://github.com/apache/flink/blob/release-1.5/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java#L44
> [2] https://stackoverflow.com/questions/44819521/how-to-set-rocksdbstatebackend-parameter-in-flink
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)