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

Add caching layer to SharedBuffer

    XMLWordPrintableJSON

Details

    Description

      With the rework of sharedBuffer Flink-9418, the lock & release operation is deal with rocksdb state which is different from the previous version which will read the state of sharedBuffer all to memory, i think we can add a cache or variable in sharedbuffer to cache the LockAble Object to mark the ref change in once process in NFA, this will reduce the count when the events point to the same NodeId.. And flush the result to MapState at the end of process. 

      Attachments

        Activity

          People

            aitozi WenJun Min
            aitozi WenJun Min
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: