You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by yh...@apache.org on 2026/06/12 13:58:51 UTC
(beam) branch master updated: Exclude testSideInputNotReadyTimer from Spark batch suites (#38939)
This is an automated email from the ASF dual-hosted git repository.
Abacn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 64bb91099a9 Exclude testSideInputNotReadyTimer from Spark batch suites (#38939)
64bb91099a9 is described below
commit 64bb91099a928ef4b8f16196102c241e215bc446
Author: Abdelrahman Ibrahim <ab...@gmail.com>
AuthorDate: Fri Jun 12 15:58:44 2026 +0200
Exclude testSideInputNotReadyTimer from Spark batch suites (#38939)
---
runners/spark/job-server/spark_job_server.gradle | 2 ++
runners/spark/spark_runner.gradle | 2 ++
2 files changed, 4 insertions(+)
diff --git a/runners/spark/job-server/spark_job_server.gradle b/runners/spark/job-server/spark_job_server.gradle
index 500a8ba865b..b2180ebf70a 100644
--- 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
index cd108372fea..1ae35b7449a 100644
--- 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'
}
}