Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-34078

Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package

    XMLWordPrintableJSON

Details

    Description

      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.

      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.

      Compatibility:

      InternalKeyContext is annotated with @Internal, so this change has no compatibility issues.

       

       

      Attachments

        1. image-2024-01-15-12-57-12-667.png
          1.16 MB
          Jinzhong Li

        Issue Links

          Activity

            People

              lijinzhong Jinzhong Li
              lijinzhong Jinzhong Li
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: