You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bo...@apache.org on 2020/11/03 23:59:54 UTC
[beam] branch master updated: Exclude SDF test suite because it
requires support of self-checkpoint.
This is an automated email from the ASF dual-hosted git repository.
boyuanz 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 0dc4afe Exclude SDF test suite because it requires support of self-checkpoint.
new f2002c6 Merge pull request #13250 from [BEAM-11187] Exclude SDF test suite because it requires support of self-checkpoint.
0dc4afe is described below
commit 0dc4afe168a53c474650279d393615a3f146b7cb
Author: Boyuan Zhang <bo...@google.com>
AuthorDate: Tue Nov 3 14:00:42 2020 -0800
Exclude SDF test suite because it requires support of self-checkpoint.
---
...Commit_Java_PortableValidatesRunner_Flink_Streaming.groovy | 11 ++++++-----
runners/flink/job-server/flink_job_server.gradle | 3 +++
2 files changed, 9 insertions(+), 5 deletions(-)
diff --git a/.test-infra/jenkins/job_PostCommit_Java_PortableValidatesRunner_Flink_Streaming.groovy b/.test-infra/jenkins/job_PostCommit_Java_PortableValidatesRunner_Flink_Streaming.groovy
index 5707a5b..e3d427e 100644
--- a/.test-infra/jenkins/job_PostCommit_Java_PortableValidatesRunner_Flink_Streaming.groovy
+++ b/.test-infra/jenkins/job_PostCommit_Java_PortableValidatesRunner_Flink_Streaming.groovy
@@ -39,10 +39,11 @@ PostcommitJobBuilder.postCommitJob('beam_PostCommit_Java_PVR_Flink_Streaming',
tasks(':runners:flink:1.10:job-server:validatesPortableRunnerStreaming')
commonJobProperties.setGradleSwitches(delegate)
}
- gradle {
- rootBuildScriptDir(commonJobProperties.checkoutDir)
- tasks(':runners:flink:1.10:job-server:validatesPortableRunnerStreamingCheckpoint')
- commonJobProperties.setGradleSwitches(delegate)
- }
+ // TODO(BEAM-10940): Enable this test suite once we have support.
+ //gradle {
+ // rootBuildScriptDir(commonJobProperties.checkoutDir)
+ // tasks(':runners:flink:1.10:job-server:validatesPortableRunnerStreamingCheckpoint')
+ // commonJobProperties.setGradleSwitches(delegate)
+ //}
}
}
diff --git a/runners/flink/job-server/flink_job_server.gradle b/runners/flink/job-server/flink_job_server.gradle
index c43865d..24b0838 100644
--- a/runners/flink/job-server/flink_job_server.gradle
+++ b/runners/flink/job-server/flink_job_server.gradle
@@ -145,6 +145,9 @@ def portableValidatesRunnerTask(String name, Boolean streaming, Boolean checkpoi
testCategories: {
if (streaming && checkpointing) {
includeCategories 'org.apache.beam.sdk.testing.UsesBundleFinalizer'
+ excludeCategories 'org.apache.beam.sdk.testing.UsesBoundedSplittableParDo'
+ // TODO(BEAM-10940): Enable this test suite once we have support.
+ excludeCategories 'org.apache.beam.sdk.testing.UsesUnboundedSplittableParDo'
// TestStreamSource does not support checkpointing
excludeCategories 'org.apache.beam.sdk.testing.UsesTestStream'
} else {