[beam] branch master updated: [BEAM-13498, BEAM-13522] Sickbay broken test and test category for Spark (#16411)

[lcwik]

This is an automated email from the ASF dual-hosted git repository.

lcwik 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 7487bf0  [BEAM-13498, BEAM-13522] Sickbay broken test and test 
category for Spark (#16411)
7487bf0 is described below

commit 7487bf0118e4c7704793112f904c7cf328caebfe
Author: Lukasz Cwik <lukec...@gmail.com>
AuthorDate: Sat Jan 1 10:50:27 2022 -0800

    [BEAM-13498, BEAM-13522] Sickbay broken test and test category for Spark 
(#16411)
---
 .../job_PostCommit_Java_PortableValidatesRunner_Spark_Batch.groovy    | 2 +-
 runners/spark/job-server/spark_job_server.gradle                      | 4 ++++
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/.test-infra/jenkins/job_PostCommit_Java_PortableValidatesRunner_Spark_Batch.groovy
 
b/.test-infra/jenkins/job_PostCommit_Java_PortableValidatesRunner_Spark_Batch.groovy
index 33914ac..3da5fed 100644
--- 
a/.test-infra/jenkins/job_PostCommit_Java_PortableValidatesRunner_Spark_Batch.groovy
+++ 
b/.test-infra/jenkins/job_PostCommit_Java_PortableValidatesRunner_Spark_Batch.groovy
@@ -25,7 +25,7 @@ 
PostcommitJobBuilder.postCommitJob('beam_PostCommit_Java_PVR_Spark_Batch',
       description('Runs the Java PortableValidatesRunner suite on the Spark 
runner in batch mode.')
 
       // Set common parameters.
-      commonJobProperties.setTopLevelMainJobProperties(delegate)
+      commonJobProperties.setTopLevelMainJobProperties(delegate, 'master', 240)
 
       // Publish all test results to Jenkins
       publishers {
diff --git a/runners/spark/job-server/spark_job_server.gradle 
b/runners/spark/job-server/spark_job_server.gradle
index 80f0839..ef23855 100644
--- a/runners/spark/job-server/spark_job_server.gradle
+++ b/runners/spark/job-server/spark_job_server.gradle
@@ -156,6 +156,8 @@ def portableValidatesRunnerTask(String name, Boolean 
streaming) {
       excludeCategories 'org.apache.beam.sdk.testing.UsesCustomWindowMerging'
       excludeCategories 'org.apache.beam.sdk.testing.UsesFailureMessage'
       excludeCategories 'org.apache.beam.sdk.testing.UsesGaugeMetrics'
+      excludeCategories 'org.apache.beam.sdk.testing.UsesPerKeyOrderedDelivery'
+      excludeCategories 'org.apache.beam.sdk.testing.UsesPerKeyOrderInBundle'
       excludeCategories 'org.apache.beam.sdk.testing.UsesParDoLifecycle'
       excludeCategories 'org.apache.beam.sdk.testing.UsesMapState'
       excludeCategories 'org.apache.beam.sdk.testing.UsesSetState'
@@ -174,6 +176,8 @@ def portableValidatesRunnerTask(String name, Boolean 
streaming) {
     testFilter = {
       // TODO (BEAM-10094)
       excludeTestsMatching 
'org.apache.beam.sdk.transforms.FlattenTest.testFlattenWithDifferentInputAndOutputCoders2'
+      // TODO(BEAM-13498)
+      excludeTestsMatching 
'org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testProcessElementSkew'
     }
   }