[beam] branch release-2.37.0 updated: [release-2.37.0][BEAM-13919] Annotate PerKeyOrderingTest with UsesStatefulParDo (#16866)

[bhulette]

This is an automated email from the ASF dual-hosted git repository.

bhulette pushed a commit to branch release-2.37.0
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/release-2.37.0 by this push:
     new d2db3f9  [release-2.37.0][BEAM-13919] Annotate PerKeyOrderingTest with 
UsesStatefulParDo (#16866)
d2db3f9 is described below

commit d2db3f9957894bfa19ce344d8c083653981857ed
Author: Brian Hulette <bhule...@google.com>
AuthorDate: Tue Feb 15 12:38:20 2022 -0800

    [release-2.37.0][BEAM-13919] Annotate PerKeyOrderingTest with 
UsesStatefulParDo (#16866)
    
    [BEAM-13919] Annotate PerKeyOrderingTest with UsesStatefulParDo.
    
    Co-authored-by: Kyle Weaver <kcwea...@google.com>
---
 .../java/org/apache/beam/sdk/transforms/PerKeyOrderingTest.java  | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/PerKeyOrderingTest.java
 
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/PerKeyOrderingTest.java
index 23c55af..b66b1ce 100644
--- 
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/PerKeyOrderingTest.java
+++ 
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/PerKeyOrderingTest.java
@@ -32,6 +32,7 @@ import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.testing.UsesPerKeyOrderInBundle;
 import org.apache.beam.sdk.testing.UsesPerKeyOrderedDelivery;
+import org.apache.beam.sdk.testing.UsesStatefulParDo;
 import org.apache.beam.sdk.testing.ValidatesRunner;
 import org.apache.beam.sdk.values.KV;
 import org.apache.beam.sdk.values.PCollection;
@@ -95,7 +96,7 @@ public class PerKeyOrderingTest implements Serializable {
   }
 
   @Test
-  @Category({ValidatesRunner.class, UsesPerKeyOrderedDelivery.class})
+  @Category({ValidatesRunner.class, UsesPerKeyOrderedDelivery.class, 
UsesStatefulParDo.class})
   public void testSingleCallOrderingWithShuffle() {
     // Here we test that the output of a single process call in a DoFn will be 
output in order
     List<Integer> perKeyElements =
@@ -136,7 +137,7 @@ public class PerKeyOrderingTest implements Serializable {
   }
 
   @Test
-  @Category({ValidatesRunner.class, UsesPerKeyOrderInBundle.class})
+  @Category({ValidatesRunner.class, UsesPerKeyOrderInBundle.class, 
UsesStatefulParDo.class})
   public void testSingleCallOrderingWithoutShuffle() {
     // Here we test that the output of a single process call in a DoFn will be 
output in order
     List<Long> perKeyElements =
@@ -219,7 +220,7 @@ public class PerKeyOrderingTest implements Serializable {
   }
 
   @Test
-  @Category({ValidatesRunner.class, UsesPerKeyOrderedDelivery.class})
+  @Category({ValidatesRunner.class, UsesPerKeyOrderedDelivery.class, 
UsesStatefulParDo.class})
   public void testMultipleStatefulOrderingWithShuffle() {
     // Here we test that the output of a single process call in a DoFn will be 
output in order
     List<Long> perKeyElements =
@@ -281,7 +282,7 @@ public class PerKeyOrderingTest implements Serializable {
   }
 
   @Test
-  @Category({ValidatesRunner.class, UsesPerKeyOrderInBundle.class})
+  @Category({ValidatesRunner.class, UsesPerKeyOrderInBundle.class, 
UsesStatefulParDo.class})
   public void testMultipleStatefulOrderingWithoutShuffle() {
     List<Integer> perKeyElements =
         Lists.newArrayList(-8, -7, -6, -5, -4, -3, -2, -1, 0, 1, 2, 3, 4, 5, 
6, 7, 8, 123456789);