From a4813971fc6b5e8734a204eb114842cc27d6d902 Mon Sep 17 00:00:00 2001 From: Jan Lukavsky Date: Tue, 5 May 2020 22:15:26 +0200 Subject: [PATCH] Disable two flaky tests (BEAM-8035, BEAM-9164) --- .../wrappers/streaming/io/UnboundedSourceWrapperTest.java | 2 ++ .../src/test/java/org/apache/beam/sdk/transforms/WatchTest.java | 2 ++ 2 files changed, 4 insertions(+) diff --git a/runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapperTest.java b/runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapperTest.java index 5a04f7ecdadcb..a008ba763dba7 100644 --- a/runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapperTest.java +++ b/runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapperTest.java @@ -66,6 +66,7 @@ import org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness; import org.apache.flink.util.InstantiationUtil; import org.apache.flink.util.OutputTag; +import org.junit.Ignore; import org.junit.Test; import org.junit.experimental.runners.Enclosed; import org.junit.runner.RunWith; @@ -242,6 +243,7 @@ public void close() {} *

This test verifies that watermarks are correctly forwarded. */ @Test(timeout = 30_000) + @Ignore("https://issues.apache.org/jira/browse/BEAM-9164") public void testWatermarkEmission() throws Exception { final int numElements = 500; PipelineOptions options = PipelineOptionsFactory.create(); diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/WatchTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/WatchTest.java index 7242ad46bf216..d1cdf09e528b4 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/WatchTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/WatchTest.java @@ -72,6 +72,7 @@ import org.joda.time.Duration; import org.joda.time.Instant; import org.joda.time.ReadableDuration; +import org.junit.Ignore; import org.junit.Rule; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -306,6 +307,7 @@ public PollResult> apply(String element, Context c) @Test @Category({NeedsRunner.class, UsesUnboundedSplittableParDo.class}) + @Ignore("https://issues.apache.org/jira/browse/BEAM-8035") public void testMultiplePollsWithManyResults() { final long numResults = 3000; List all = Lists.newArrayList();