Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-7156

Nexmark Query 14 'SESSION_SIDE_INPUT_JOIN' is producing twice the number of results in Spark Runner

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: P3
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.19.0
    • Component/s: runner-spark
    • Labels:
      None

      Description

      Running the same query with Direct runner and Flink produces 92000 results for the default config but in Spark it is producing twice as much 184000

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                iemejia Ismaël Mejía
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: