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

Migrate SharedBuffer to use MapState

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 1.6.0
    • Library / CEP
    • None

    Description

      Right now SharedBuffer is implemented with java Collections and the whole buffer is deserialized on each access. We should migrate it to MapState, so that only the necessary parts (e.g. tail entries) are deserialized.

      Attachments

        Issue Links

          Activity

            People

              dwysakowicz Dawid Wysakowicz
              dwysakowicz Dawid Wysakowicz
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: