Jinzhong Li created FLINK-34078:
-----------------------------------
Summary: Move InternalKeyContext classes from
o.a.f.runtime.state.heap to o.a.f.runtime.state package
Key: FLINK-34078
URL: https://issues.apache.org/jira/browse/FLINK-34078
Project: Flink
Issue Type: Improvement
Components: Runtime / State Backends
Reporter: Jinzhong Li
Attachments: image-2024-01-15-12-57-12-667.png
h3. Motication:
When Rocksdb statebackend throws a keyGroup check illegal exception,
the exception stack contains the heap stateBackend scoped class, which looks so
strange to user.
!image-2024-01-15-12-57-12-667.png|width=555,height=68!
h3. Proposed changes:
InternalKeyContext and InternalKeyContextImpl are commonly used by all state
backends (heap/rocksdb/changelog), they should be moved from
org.apache.flink.runtime.state.heap package to org.apache.flink.runtime.state
package.
h3. Compatibility:
InternalKeyContext is annotated with @Internal, so this change has no
compatibility issues.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)