You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by em...@apache.org on 2021/12/23 00:26:08 UTC
[beam] branch master updated: [BEAM-13525] Sickbay new PardoTests for Dataflow V2 Java Streaming VR (#16328)
This is an automated email from the ASF dual-hosted git repository.
emilyye 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 67e435d9 [BEAM-13525] Sickbay new PardoTests for Dataflow V2 Java Streaming VR (#16328)
67e435d9 is described below
commit 67e435d96196de7892decd322491325dccf0b984
Author: emily <em...@google.com>
AuthorDate: Wed Dec 22 16:25:11 2021 -0800
[BEAM-13525] Sickbay new PardoTests for Dataflow V2 Java Streaming VR (#16328)
---
runners/flink/job-server/flink_job_server.gradle | 2 +-
runners/google-cloud-dataflow-java/build.gradle | 6 ++++++
2 files changed, 7 insertions(+), 1 deletion(-)
diff --git a/runners/flink/job-server/flink_job_server.gradle b/runners/flink/job-server/flink_job_server.gradle
index 96b1770..3dd07bc 100644
--- a/runners/flink/job-server/flink_job_server.gradle
+++ b/runners/flink/job-server/flink_job_server.gradle
@@ -192,7 +192,7 @@ def portableValidatesRunnerTask(String name, Boolean streaming, Boolean checkpoi
excludeTestsMatching 'org.apache.beam.sdk.testing.TestStreamTest.testLateDataAccumulating'
// TODO(BEAM-12710)
excludeTestsMatching 'org.apache.beam.sdk.testing.TestStreamTest.testFirstElementLate'
- // TODO(BEAM-12498)
+ // TODO(BEAM-13498)
excludeTestsMatching 'org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testProcessElementSkew'
},
)
diff --git a/runners/google-cloud-dataflow-java/build.gradle b/runners/google-cloud-dataflow-java/build.gradle
index 75b3785..bec6de6 100644
--- a/runners/google-cloud-dataflow-java/build.gradle
+++ b/runners/google-cloud-dataflow-java/build.gradle
@@ -437,7 +437,9 @@ task validatesRunnerV2Streaming {
'org.apache.beam.sdk.transforms.ReshuffleTest.testReshuffleWithTimestampsStreaming',
'org.apache.beam.sdk.transforms.ParDoTest$OnWindowExpirationTests.testOnWindowExpirationSimpleBounded',
+ 'org.apache.beam.sdk.transforms.ParDoTest$OnWindowExpirationTests.testOnWindowExpirationSimpleBoundedGlobal',
'org.apache.beam.sdk.transforms.ParDoTest$OnWindowExpirationTests.testOnWindowExpirationSimpleUnbounded',
+ 'org.apache.beam.sdk.transforms.ParDoTest$OnWindowExpirationTests.testOnWindowExpirationSimpleUnboundedGlobal',
// TODO(BEAM-11858) reading a side input twice fails
'org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testSameSideInputReadTwice',
@@ -487,6 +489,10 @@ task validatesRunnerV2Streaming {
// TODO(BEAM-12353): Identify whether it's bug or a feature gap.
'org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests.testRewindowWithTimestampCombiner',
+
+ // TODO(BEAM-13525)
+ 'org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testProcessElementSkew',
+ 'org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testOnWindowTimestampSkew',
]
))
}