sickbay new reshuffle test on runners that do not support it

apache · Jan 16, 2024 · cf20119 · cf20119
1 parent c11b7c1
commit cf20119
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 0 deletions.
diff --git a/runners/portability/java/build.gradle b/runners/portability/java/build.gradle
@@ -200,6 +200,9 @@ def createUlrValidatesRunnerTask = { name, environmentType, dockerImageTask = ""
       // https://github.com/apache/beam/issues/20374
       excludeTestsMatching 'org.apache.beam.sdk.transforms.CombineTest$BasicTests.testHotKeyCombiningWithAccumulationMode'
 
+      // TODO(https://github.com/apache/beam/issues/29973)
+      excludeTestsMatching 'org.apache.beam.sdk.transforms.ReshuffleTest.testReshufflePreservesMetadata'
+
       for (String test : sickbayTests) {
         excludeTestsMatching test
       }

diff --git a/runners/samza/job-server/build.gradle b/runners/samza/job-server/build.gradle
@@ -182,6 +182,8 @@ def portableValidatesRunnerTask(String name, boolean docker) {
             excludeTestsMatching 'org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testProcessElementSkew'
             // TODO(https://github.com/apache/beam/issues/22650)
             excludeTestsMatching 'org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState'
+            // TODO(https://github.com/apache/beam/issues/29973)
+            excludeTestsMatching 'org.apache.beam.sdk.transforms.ReshuffleTest.testReshufflePreservesMetadata'
         }
   )
 }

diff --git a/runners/spark/job-server/spark_job_server.gradle b/runners/spark/job-server/spark_job_server.gradle
@@ -157,6 +157,8 @@ def portableValidatesRunnerTask(String name, boolean streaming, boolean docker,
         excludeTestsMatching 'org.apache.beam.sdk.transforms.windowing.WindowingTest'
         // // Assertion error: incorrect output
         excludeTestsMatching 'CombineTest$BasicTests.testHotKeyCombining'
+        // TODO(https://github.com/apache/beam/issues/29973)
+        excludeTestsMatching 'org.apache.beam.sdk.transforms.ReshuffleTest.testReshufflePreservesMetadata'
       }
     }
     else {

diff --git a/runners/spark/spark_runner.gradle b/runners/spark/spark_runner.gradle
@@ -321,6 +321,8 @@ def validatesRunnerStreaming = tasks.register("validatesRunnerStreaming", Test)
       // UNBOUNDED View.CreatePCollectionView not supported
       excludeTestsMatching 'org.apache.beam.sdk.transforms.ParDoTest$BundleInvariantsTests.testWatermarkUpdateMidBundle'
       excludeTestsMatching 'org.apache.beam.sdk.transforms.ViewTest.testWindowedSideInputNotPresent'
+      // TODO(https://github.com/apache/beam/issues/29973)
+      excludeTestsMatching 'org.apache.beam.sdk.transforms.ReshuffleTest.testReshufflePreservesMetadata'
     }
 
     // TestStream using processing time is not supported in Spark