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

Consider removing UnknownInputChannel in NettyShuffleEnvironment

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Reopened
    • Not a Priority
    • Resolution: Unresolved
    • None
    • None
    • Runtime / Network
    • None

    Description

      UnknownInputChannel basically is a place holder while the producer is unknown which contains some partition parameters to use later for creation of the known channel.

      If NettyShuffleEnvironment#updatePartitionInfo provides enough information to add the known channel, one could consider removing UnknownInputChannel and refactoring indexed channel array into a dynamic list.

      Initially suggested in https://github.com/apache/flink/pull/8362#discussion_r290308989

      Attachments

        Activity

          People

            Unassigned Unassigned
            azagrebin Andrey Zagrebin
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated: