Yun Tang created FLINK-23798:
--------------------------------
Summary: Avoid using reflection to get filter when partition
filter is enabled
Key: FLINK-23798
URL: https://issues.apache.org/jira/browse/FLINK-23798
Project: Flink
Issue Type: Improvement
Components: Runtime / State Backends
Reporter: Yun Tang
Fix For: 1.14.0
FLINK-20496 introduce partitioned index & filter to Flink. However, RocksDB
only support new full format of filter in this feature, and we need to replace
previous filter if user enabled. [Previous implementation use reflection to get
the
filter|https://github.com/apache/flink/blob/7ff4cbdc25aa971dccaf5ce02aaf46dc1e7345cc/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java#L251-L258]
and we could use API to get that after upgrading to newer version.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
