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

BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

    XMLWordPrintableJSON

    Details

      Description

      BoundedBlockingSubpartition may leak network buffer if task is failed or canceled. We need to recycle the current BufferConsumer when task is failed or canceled.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                nicholasjiang Nicholas Jiang
                Reporter:
                kevin.cyj Yingjie Cao
              • Votes:
                0 Vote for this issue
                Watchers:
                6 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: