[
https://issues.apache.org/jira/browse/FLINK-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-11084:
----------------------------------------
Fix Version/s: (was: 1.6.3)
1.6.4
> Incorrect ouput after two consecutive 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
> Priority: Critical
> Labels: pull-request-available
> Fix For: 1.5.6, 1.6.4, 1.7.2, 1.8.0
>
>
> 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)
