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

Channel state iterator is accessed concurrently without proper synchronization

    XMLWordPrintableJSON

Details

    Description

      ChannelStateWriter adds input/output data that is written by a dedicated thread.

      The data is passed as CloseableIterator.

      In some cases, iterator.close can be called from the task thread which can lead to double release of buffers.

      Attachments

        Issue Links

          Activity

            People

              roman Roman Khachatryan
              roman Roman Khachatryan
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: