[FLINK-12603] Remove getOwningTaskName method from InputGate

• Type: Sub-task
• Status: Resolved
• Priority: Minor
• Resolution: Done
• Fix Version/s: 1.9.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Zhijiang
• Reporter: Zhijiang
• Created: 23/May/19 11:18
• Updated: 05/Jun/19 12:37
• Resolved: 05/Jun/19 12:35

Description

In order to make abstract InputGate simple for extending new implementations in shuffle service architecture, we could remove unnecessary methods from it.

Currently InputGate#getOwningTaskName is only used for debugging log in BarrierBuffer and StreamInputProcessor. This task name could be got from Environment#getTaskInfo and then be passed into the constructor of BarrierBuffer/StreamInputProcessor for use.

Issue Links

• links to: GitHub Pull Request #8529