[beam] branch master updated: [BEAM-13525] Sickbay new PardoTests for Dataflow V2 Java Streaming VR (#16328)

[emilyye]

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 <emil...@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',
     ]
   ))
 }