Exclude testSideInputNotReadyTimer from Spark batch suites (#38939)

aIbrahiim · web-flow · commit 64bb91099a92 · 2026-06-12T09:58:44.000-04:00
diff --git a/runners/spark/job-server/spark_job_server.gradle b/runners/spark/job-server/spark_job_server.gradle
@@ -210,6 +210,8 @@ def portableValidatesRunnerTask(String name, boolean streaming, boolean docker,
         excludeTestsMatching 'org.apache.beam.sdk.transforms.FlattenTest.testFlattenWithDifferentInputAndOutputCoders2'
         // TODO(https://github.com/apache/beam/issues/31231)
         excludeTestsMatching 'org.apache.beam.sdk.transforms.RedistributeTest.testRedistributePreservesMetadata'
+        // Spark does not support side inputs in timers (added in #38363)
+        excludeTestsMatching 'org.apache.beam.sdk.transforms.ParDoTest$StateTests.testSideInputNotReadyTimer'
         for (String test : sickbayTests) {
           excludeTestsMatching test
         }
diff --git a/runners/spark/spark_runner.gradle b/runners/spark/spark_runner.gradle
@@ -406,6 +406,8 @@ def validatesRunnerBatch = tasks.register("validatesRunnerBatch", Test) {
     excludeTestsMatching 'org.apache.beam.sdk.transforms.RedistributeTest.testRedistributePreservesMetadata'
     // TODO(https://github.com/apache/beam/issues/32021)
     excludeTestsMatching 'org.apache.beam.sdk.metrics.MetricsTest$AttemptedMetricTests.testBoundedSourceMetricsInSplit'
+    // Spark does not support side inputs in timers (added in #38363)
+    excludeTestsMatching 'org.apache.beam.sdk.transforms.ParDoTest$StateTests.testSideInputNotReadyTimer'
   }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -210,6 +210,8 @@ def portableValidatesRunnerTask(String name, boolean streaming, boolean docker,`
`210`	`210`	`excludeTestsMatching 'org.apache.beam.sdk.transforms.FlattenTest.testFlattenWithDifferentInputAndOutputCoders2'`
`211`	`211`	`// TODO(https://github.com/apache/beam/issues/31231)`
`212`	`212`	`excludeTestsMatching 'org.apache.beam.sdk.transforms.RedistributeTest.testRedistributePreservesMetadata'`
	`213`	`+ // Spark does not support side inputs in timers (added in #38363)`
	`214`	`+ excludeTestsMatching 'org.apache.beam.sdk.transforms.ParDoTest$StateTests.testSideInputNotReadyTimer'`
`213`	`215`	`for (String test : sickbayTests) {`
`214`	`216`	`excludeTestsMatching test`
`215`	`217`	`}`
Original file line number	Diff line number	Diff line change
`@@ -406,6 +406,8 @@ def validatesRunnerBatch = tasks.register("validatesRunnerBatch", Test) {`
`406`	`406`	`excludeTestsMatching 'org.apache.beam.sdk.transforms.RedistributeTest.testRedistributePreservesMetadata'`
`407`	`407`	`// TODO(https://github.com/apache/beam/issues/32021)`
`408`	`408`	`excludeTestsMatching 'org.apache.beam.sdk.metrics.MetricsTest$AttemptedMetricTests.testBoundedSourceMetricsInSplit'`
	`409`	`+ // Spark does not support side inputs in timers (added in #38363)`
	`410`	`+ excludeTestsMatching 'org.apache.beam.sdk.transforms.ParDoTest$StateTests.testSideInputNotReadyTimer'`
`409`	`411`	`}`
`410`	`412`	`}`
`411`	`413`