Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-7126

Double encoding of state keys in portable Flink runner

    XMLWordPrintableJSON

Details

    Description

      State keys currently need to be encoded as NESTED. My attempt to use the ByteString directly in BEAM-7112 caused checkpointing to fail. We should look into eliminating the redundant key encoding and adjusting StateRequestHandlers.

      Attachments

        Issue Links

          blocks

          Improvement - An improvement or enhancement to an existing feature or task. BEAM-7271 Adding StringUtf8Coder to ModelCoder in JavaSDK [REOPENED]

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Resolved
          is related to

          Bug - A problem which impairs or prevents the functions of the product. BEAM-7112 State cleanup interferes with user timer callback

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Resolved
          links to

          Web Link GitHub Pull Request #8472

          Web Link GitHub Pull Request #8697

          Activity

            People

              mxm Maximilian Michels
              thw Thomas Weise
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 4h 10m
                  4h 10m