Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-11084

Incorrect ouput after two consecutive split and select

    Details

      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}

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                dangdangdang Shimin Yang
                Reporter:
                dangdangdang Shimin Yang
              • Votes:
                0 Vote for this issue
                Watchers:
                5 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 - 10m
                  10m