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)

Reply via email to