You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ja...@apache.org on 2019/10/25 10:04:13 UTC
[beam] branch master updated: [BEAM-7520] ignore
UsesStrictTimerOrdering for both batch and streaming flink
This is an automated email from the ASF dual-hosted git repository.
janl 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 4725b54 [BEAM-7520] ignore UsesStrictTimerOrdering for both batch and streaming flink
new 21f9fe1 Merge pull request #9869 from je-ik/BEAM-7520-ignore-timer-ordering-for-flink-pvr-batch:[BEAM-7520] ignore UsesStrictTimerOrdering for Flink
4725b54 is described below
commit 4725b54fe457ee44c733a83b0d34adb50ff193ae
Author: Jan Lukavsky <je...@seznam.cz>
AuthorDate: Thu Oct 24 16:34:45 2019 +0200
[BEAM-7520] ignore UsesStrictTimerOrdering for both batch and streaming flink
---
runners/flink/job-server/flink_job_server.gradle | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/runners/flink/job-server/flink_job_server.gradle b/runners/flink/job-server/flink_job_server.gradle
index d6664cc..560f195 100644
--- a/runners/flink/job-server/flink_job_server.gradle
+++ b/runners/flink/job-server/flink_job_server.gradle
@@ -147,9 +147,9 @@ def portableValidatesRunnerTask(String name, Boolean streaming) {
excludeCategories 'org.apache.beam.sdk.testing.UsesParDoLifecycle'
excludeCategories 'org.apache.beam.sdk.testing.UsesMapState'
excludeCategories 'org.apache.beam.sdk.testing.UsesSetState'
+ excludeCategories 'org.apache.beam.sdk.testing.UsesStrictTimerOrdering'
if (streaming) {
excludeCategories 'org.apache.beam.sdk.testing.UsesTestStreamWithProcessingTime'
- excludeCategories 'org.apache.beam.sdk.testing.UsesStrictTimerOrdering'
} else {
excludeCategories 'org.apache.beam.sdk.testing.UsesTestStream'
}