From b2f7c90ea87cd88e7edbdeced7435b948cc2ff95 Mon Sep 17 00:00:00 2001 From: Shunping Huang Date: Tue, 20 Jan 2026 13:03:12 -0500 Subject: [PATCH 1/2] Enable some tests in runner v2 batch mode. --- .../beam_PostCommit_Java_ValidatesRunner_Dataflow_V2.json | 2 +- runners/google-cloud-dataflow-java/build.gradle | 2 -- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_V2.json b/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_V2.json index 794c7aabad6b..8bbe16c113f1 100644 --- a/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_V2.json +++ b/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_V2.json @@ -1,4 +1,4 @@ { "comment": "Modify this file in a trivial way to cause this test suite to run!", - "modification": 2 + "modification": 3 } diff --git a/runners/google-cloud-dataflow-java/build.gradle b/runners/google-cloud-dataflow-java/build.gradle index 3792626a1fdf..db0e48db4fa4 100644 --- a/runners/google-cloud-dataflow-java/build.gradle +++ b/runners/google-cloud-dataflow-java/build.gradle @@ -546,8 +546,6 @@ task validatesRunnerV2 { name: 'validatesRunnerV2Test', pipelineOptions: runnerV2PipelineOptions, excludedCategories: [ - 'org.apache.beam.sdk.testing.UsesOnWindowExpiration', - 'org.apache.beam.sdk.testing.UsesStatefulParDo', 'org.apache.beam.sdk.testing.UsesTimersInParDo', 'org.apache.beam.sdk.testing.UsesUnboundedPCollections', 'org.apache.beam.sdk.testing.UsesUnboundedSplittableParDo', From 0b5c324e1e92ffff2a317d7c6c242bb956780951 Mon Sep 17 00:00:00 2001 From: Shunping Huang Date: Wed, 21 Jan 2026 12:21:49 -0500 Subject: [PATCH 2/2] Skip the failed tests after re-enabling some categories. --- runners/google-cloud-dataflow-java/build.gradle | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/runners/google-cloud-dataflow-java/build.gradle b/runners/google-cloud-dataflow-java/build.gradle index db0e48db4fa4..6f25803b8483 100644 --- a/runners/google-cloud-dataflow-java/build.gradle +++ b/runners/google-cloud-dataflow-java/build.gradle @@ -553,6 +553,10 @@ task validatesRunnerV2 { excludedTests: [ 'org.apache.beam.sdk.transforms.ReshuffleTest.testReshuffleWithTimestampsStreaming', + // TODO(https://github.com/apache/beam/issues/37371): Identify the cause of assertion failure for these tests + 'org.apache.beam.runners.dataflow.DataflowRunnerTest.testBatchGroupIntoBatchesOverrideBytes', + 'org.apache.beam.runners.dataflow.DataflowRunnerTest.testBatchGroupIntoBatchesOverrideCount', + // These tests use static state and don't work with remote execution. 'org.apache.beam.sdk.transforms.ParDoLifecycleTest.testTeardownCalledAfterExceptionInFinishBundle', 'org.apache.beam.sdk.transforms.ParDoLifecycleTest.testTeardownCalledAfterExceptionInFinishBundleStateful',