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

    • Bug
    • Status: Resolved
    • P3
    • Resolution: Fixed
    • None
    • 2.19.0
    • runner-spark
    • 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

          is fixed by

          Bug - A problem which impairs or prevents the functions of the product. BEAM-9065 Spark runner accumulates metrics (incorrectly) between runs

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Triage Needed

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: