This is an automated email from the ASF dual-hosted git repository. Amar3tto pushed a commit to branch fix-flink-batch in repository https://gitbox.apache.org/repos/asf/beam.git
commit 7bfacc2e9529bdf71c417de6294fea757476e9a4 Author: Vitaly Terentyev <[email protected]> AuthorDate: Tue Jun 16 22:48:18 2026 +0400 Exclude tests for batch-dataset --- runners/flink/job-server/flink_job_server.gradle | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/runners/flink/job-server/flink_job_server.gradle b/runners/flink/job-server/flink_job_server.gradle index b85f8fc98aa..e7329c6eea1 100644 --- a/runners/flink/job-server/flink_job_server.gradle +++ b/runners/flink/job-server/flink_job_server.gradle @@ -79,6 +79,9 @@ configurations.all { exclude group: "commons-logging", module: "commons-logging" } +excludeTestsMatching 'org.apache.beam.sdk.transforms.ParDoTest$StateTests.testSideInputNotReadyTimer' +excludeTestsMatching 'org.apache.beam.sdk.transforms.ParDoTest$StateTests.testTimerSideInput' + dependencies { implementation project(flinkRunnerProject) permitUnusedDeclared project(flinkRunnerProject) // BEAM-11761 @@ -193,7 +196,7 @@ def portableValidatesRunnerTask(String name, String mode, boolean checkpointing, excludeCategories 'org.apache.beam.sdk.testing.UsesTriggeredSideInputs' return } - if (mode == "batch") { + if (mode == "batch" || mode == "batch-dataset") { excludeCategories 'org.apache.beam.sdk.testing.UsesTriggeredSideInputs' } excludeCategories 'org.apache.beam.sdk.testing.UsesUnboundedSplittableParDo'
