Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-10653 Introduce Pluggable Shuffle Service Architecture
  3. FLINK-11604

Extend the necessary methods in ResultPartitionWriter interface

    XMLWordPrintableJSON

    Details

      Description

      This is a preparation work for future creating ResultPartitionWriter via proposed ShuffleService.

      Currently there exists only one ResultPartition implementation for ResultPartitionWriter interface, so the specific ResultPartition instance is easily referenced in many other classes such as Task, NetworkEnvironment, etc. Even some private methods in ResultPartition would be called directly in these reference classes.

      Considering ShuffleService might create multiple different ResultPartitionWriter implementations future, then all the other classes should only reference with the interface and call the common methods. Therefore we extend the related methods in ResultPartitionWriter interface in order to cover existing logics in ResultPartition.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                zjwang Zhijiang
                Reporter:
                zjwang Zhijiang
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m