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

Flink runner does not support PerKeyOrdering

Details

    • New Feature
    • Status: Open
    • P3
    • Resolution: Unresolved
    • None
    • None
    • runner-flink
    • None

    Description

      These tests were newly added and do not pass on the Flink runner. They can be excluded for now.

      org.apache.beam.sdk.transforms.PerKeyOrderingTest.testSingleCallOrderingWithShuffle
      org.apache.beam.sdk.transforms.PerKeyOrderingTest.testSingleCallOrderingWithoutShuffle

      java.lang.AssertionError: Verify/ParMultiDo(Verify).output:
      Expected: iterable with items [<KV

      {k1, true}

      >, <KV

      {k2, true}

      >, <KV

      {k3, true}

      >, <KV

      {k4, true}

      >, <KV

      {k5, true}

      >, <KV

      {k6, true}

      >, <KV

      {k7, true}

      >, <KV

      {k8, true}

      >, <KV

      {k9, true}

      >, <KV

      {k10, true}

      >] in any order
      but: not matched: <KV

      {k10, false}

      >

      Attachments

        Activity

          People

            Unassigned Unassigned
            ibzib Kyle Weaver
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: