Skip to content

Commit 3af92db

Browse files
committed
Enable MapState, SetState, MultimapState validates runner tests for dataflow.
1 parent d134f24 commit 3af92db

File tree

5 files changed

+4
-12
lines changed

5 files changed

+4
-12
lines changed
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
{
22
"https://github.com/apache/beam/pull/34902": "Introducing OutputBuilder",
33
"comment": "Modify this file in a trivial way to cause this test suite to run",
4-
"modification": 2,
4+
"modification": 3,
55
"https://github.com/apache/beam/pull/34294": "noting that PR #34294 should run this test",
66
"https://github.com/apache/beam/pull/35159": "moving WindowedValue and making an interface"
77
}

.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_Streaming.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
{
22
"https://github.com/apache/beam/pull/34902": "Introducing OutputBuilder",
33
"comment": "Modify this file in a trivial way to cause this test suite to run",
4+
"modification": 1,
45
"https://github.com/apache/beam/pull/31156": "noting that PR #31156 should run this test",
56
"https://github.com/apache/beam/pull/31268": "noting that PR #31268 should run this test",
67
"https://github.com/apache/beam/pull/31490": "noting that PR #31490 should run this test",
Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,5 @@
11
{
22
"https://github.com/apache/beam/pull/34902": "Introducing OutputBuilder",
33
"comment": "Modify this file in a trivial way to cause this test suite to run",
4-
"https://github.com/apache/beam/pull/31156": "noting that PR #31156 should run this test",
5-
"https://github.com/apache/beam/pull/31268": "noting that PR #31268 should run this test",
6-
"https://github.com/apache/beam/pull/31490": "noting that PR #31490 should run this test",
7-
"https://github.com/apache/beam/pull/35159": "moving WindowedValue and making an interface"
4+
"modification": 1,
85
}

.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Dataflow_V2_Streaming.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
{
22
"https://github.com/apache/beam/pull/34902": "Introducing OutputBuilder",
33
"comment": "Modify this file in a trivial way to cause this test suite to run",
4+
"modification": 1,
45
"https://github.com/apache/beam/pull/31156": "noting that PR #31156 should run this test",
56
"https://github.com/apache/beam/pull/31268": "noting that PR #31268 should run this test",
67
"https://github.com/apache/beam/pull/31490": "noting that PR #31490 should run this test"

runners/google-cloud-dataflow-java/build.gradle

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -203,7 +203,6 @@ def commonLegacyExcludeCategories = [
203203
'org.apache.beam.sdk.testing.UsesExternalService',
204204
'org.apache.beam.sdk.testing.UsesDistributionMetrics',
205205
'org.apache.beam.sdk.testing.UsesGaugeMetrics',
206-
'org.apache.beam.sdk.testing.UsesMultimapState',
207206
'org.apache.beam.sdk.testing.UsesTestStream',
208207
'org.apache.beam.sdk.testing.UsesParDoLifecycle', // doesn't support remote runner
209208
'org.apache.beam.sdk.testing.UsesMetricsPusher',
@@ -214,11 +213,7 @@ def commonLegacyExcludeCategories = [
214213
def commonRunnerV2ExcludeCategories = [
215214
'org.apache.beam.sdk.testing.UsesExternalService',
216215
'org.apache.beam.sdk.testing.UsesGaugeMetrics',
217-
'org.apache.beam.sdk.testing.UsesSetState',
218-
'org.apache.beam.sdk.testing.UsesMapState',
219-
'org.apache.beam.sdk.testing.UsesMultimapState',
220216
'org.apache.beam.sdk.testing.UsesMetricsPusher',
221-
'org.apache.beam.sdk.testing.UsesOrderedListState',
222217
'org.apache.beam.sdk.testing.UsesTestStream',
223218
'org.apache.beam.sdk.testing.UsesTestStreamWithProcessingTime',
224219
'org.apache.beam.sdk.testing.UsesRequiresTimeSortedInput',
@@ -464,9 +459,7 @@ task validatesRunnerStreaming {
464459
pipelineOptions: legacyPipelineOptions + ['--streaming'],
465460
excludedCategories: [
466461
'org.apache.beam.sdk.testing.UsesCommittedMetrics',
467-
'org.apache.beam.sdk.testing.UsesMapState',
468462
'org.apache.beam.sdk.testing.UsesRequiresTimeSortedInput',
469-
'org.apache.beam.sdk.testing.UsesSetState',
470463
],
471464
excludedTests: [
472465
// TODO(https://github.com/apache/beam/issues/21472)

0 commit comments

Comments
 (0)