Shimin Yang created FLINK-11084: ----------------------------------- Summary: Incorrect ouput after two successive split and select Key: FLINK-11084 URL: https://issues.apache.org/jira/browse/FLINK-11084 Project: Flink Issue Type: Bug Components: Streaming Reporter: Shimin Yang Assignee: Shimin Yang Fix For: 1.5.6, 1.6.3, 1.8.0, 1.7.1
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} -- This message was sent by Atlassian JIRA (v7.6.3#76005)