[BEAM-13572] Flink runner does not support PerKeyOrdering

• Type: New Feature
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: runner-flink
• Assignee: Unassigned
• Reporter: Kyle Weaver
• Created: 28/Dec/21 17:28
• Updated: 04/Jun/22 22:38

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}

>