This is an automated email from the ASF dual-hosted git repository.
scwhittle 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 3d5d04b9f39 Enable some advanced state validates runner tests for
dataflow legacy and v2. (#36808)
3d5d04b9f39 is described below
commit 3d5d04b9f39906be410943b5e71f70095bde20d2
Author: Sam Whittle <[email protected]>
AuthorDate: Fri Nov 21 11:18:05 2025 +0100
Enable some advanced state validates runner tests for dataflow legacy and
v2. (#36808)
---
.../beam_PostCommit_Java_ValidatesRunner_Dataflow.json | 5 +----
.../beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming.json | 7 +------
.../beam_PostCommit_Java_ValidatesRunner_Dataflow_V2.json | 7 +------
...beam_PostCommit_Java_ValidatesRunner_Dataflow_V2_Streaming.json | 5 +----
runners/google-cloud-dataflow-java/build.gradle | 7 +++----
5 files changed, 7 insertions(+), 24 deletions(-)
diff --git
a/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow.json
b/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow.json
index 2d05fc1b5d1..df920af419a 100644
--- a/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow.json
+++ b/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow.json
@@ -1,7 +1,4 @@
{
- "https://github.com/apache/beam/pull/34902": "Introducing OutputBuilder",
"comment": "Modify this file in a trivial way to cause this test suite to
run",
- "modification": 2,
- "https://github.com/apache/beam/pull/34294": "noting that PR #34294 should
run this test",
- "https://github.com/apache/beam/pull/35159": "moving WindowedValue and
making an interface"
+ "modification": 3,
}
diff --git
a/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming.json
b/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming.json
index 743ee4b948f..f7c66d31909 100644
---
a/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming.json
+++
b/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming.json
@@ -1,9 +1,4 @@
{
- "https://github.com/apache/beam/pull/34902": "Introducing OutputBuilder",
"comment": "Modify this file in a trivial way to cause this test suite to
run",
- "https://github.com/apache/beam/pull/31156": "noting that PR #31156 should
run this test",
- "https://github.com/apache/beam/pull/31268": "noting that PR #31268 should
run this test",
- "https://github.com/apache/beam/pull/31490": "noting that PR #31490 should
run this test",
- "https://github.com/apache/beam/pull/35159": "moving WindowedValue and
making an interface",
- "https://github.com/apache/beam/pull/36631": "dofn lifecycle",
+ "modification": 1,
}
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 47d924953c5..b2683333323 100644
---
a/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_V2.json
+++
b/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_V2.json
@@ -1,9 +1,4 @@
{
- "https://github.com/apache/beam/pull/34902": "Introducing OutputBuilder",
"comment": "Modify this file in a trivial way to cause this test suite to
run",
- "https://github.com/apache/beam/pull/31156": "noting that PR #31156 should
run this test",
- "https://github.com/apache/beam/pull/31268": "noting that PR #31268 should
run this test",
- "https://github.com/apache/beam/pull/31490": "noting that PR #31490 should
run this test",
- "https://github.com/apache/beam/pull/35159": "moving WindowedValue and
making an interface",
- "https://github.com/apache/beam/pull/36631": "dofn lifecycle validation",
+ "modification": 2
}
diff --git
a/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_V2_Streaming.json
b/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_V2_Streaming.json
index 7dab8be7160..6299c7b1243 100644
---
a/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_V2_Streaming.json
+++
b/.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_V2_Streaming.json
@@ -1,7 +1,4 @@
{
- "https://github.com/apache/beam/pull/34902": "Introducing OutputBuilder",
"comment": "Modify this file in a trivial way to cause this test suite to
run",
- "https://github.com/apache/beam/pull/31156": "noting that PR #31156 should
run this test",
- "https://github.com/apache/beam/pull/31268": "noting that PR #31268 should
run this test",
- "https://github.com/apache/beam/pull/31490": "noting that PR #31490 should
run this test"
+ "modification": 1,
}
diff --git a/runners/google-cloud-dataflow-java/build.gradle
b/runners/google-cloud-dataflow-java/build.gradle
index 0961a385b21..3e5ff263765 100644
--- a/runners/google-cloud-dataflow-java/build.gradle
+++ b/runners/google-cloud-dataflow-java/build.gradle
@@ -205,7 +205,6 @@ def commonLegacyExcludeCategories = [
'org.apache.beam.sdk.testing.UsesExternalService',
'org.apache.beam.sdk.testing.UsesDistributionMetrics',
'org.apache.beam.sdk.testing.UsesGaugeMetrics',
- 'org.apache.beam.sdk.testing.UsesMultimapState',
'org.apache.beam.sdk.testing.UsesTestStream',
'org.apache.beam.sdk.testing.UsesMetricsPusher',
'org.apache.beam.sdk.testing.UsesBundleFinalizer',
@@ -219,7 +218,6 @@ def commonRunnerV2ExcludeCategories = [
'org.apache.beam.sdk.testing.UsesMapState',
'org.apache.beam.sdk.testing.UsesMultimapState',
'org.apache.beam.sdk.testing.UsesMetricsPusher',
- 'org.apache.beam.sdk.testing.UsesOrderedListState',
'org.apache.beam.sdk.testing.UsesTestStream',
'org.apache.beam.sdk.testing.UsesTestStreamWithProcessingTime',
'org.apache.beam.sdk.testing.UsesRequiresTimeSortedInput',
@@ -450,6 +448,9 @@ task validatesRunner {
description "Validates Dataflow runner"
dependsOn(createLegacyWorkerValidatesRunnerTest(
name: 'validatesRunnerLegacyWorkerTest',
+ excludedCategories: [
+ 'org.apache.beam.sdk.testing.UsesMultimapState',
+ ],
excludedTests: [
// TODO(https://github.com/apache/beam/issues/21472)
'org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState',
@@ -475,9 +476,7 @@ task validatesRunnerStreaming {
pipelineOptions: legacyPipelineOptions + ['--streaming'],
excludedCategories: [
'org.apache.beam.sdk.testing.UsesCommittedMetrics',
- 'org.apache.beam.sdk.testing.UsesMapState',
'org.apache.beam.sdk.testing.UsesRequiresTimeSortedInput',
- 'org.apache.beam.sdk.testing.UsesSetState',
],
excludedTests: [
// TODO(https://github.com/apache/beam/issues/21472)
