[FLINK-11084] Incorrect ouput after two consecutive split and select

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 1.6.4, 1.7.2, 1.8.0
• Labels: pull-request-available
• Assignee: Shimin Yang
• Reporter: Shimin Yang
• Created: 06/Dec/18 06:32
• Updated: 01/Sep/20 10:55
• Resolved: 11/Jan/19 08:55

Description

The second OutputSelector of two successive split and select are actually not rely on the first one. They are in the same array of OutputSelector in DirectedOutput.

For example.

outputSelector1 => {“name1” or ”name2“}

outputSelector2 => {”name3“ or “name4”}

resultStream = dataStream.split(outputSelector1).select("name2").split(outputSelector2).select("name3")

expectedResult for input {StreamRecord1}:

outputSelector1 => {”name1“}

outputSelector2 => {”name3“}

resultStream => {}

actualResult:

resultStream => {StreamRecord1}

Issue Links

• duplicates: FLINK-1772 Chain of split/select does not work
• duplicates: FLINK-5031 Consecutive DataStream.split() ignored
• relates to: FLINK-19083 Remove deprecated DataStream#split
• links to: GitHub Pull Request #7258
• links to: Github Pull Request #7258