Repository: beam Updated Branches: refs/heads/master ed0d4577d -> 5ca149de2
[BEAM-1526] Suppress Spark WatermarkTest#testInDoFn due to flakes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/146ce988 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/146ce988 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/146ce988 Branch: refs/heads/master Commit: 146ce9884e8ff4781526c41f051915d526af5801 Parents: ed0d457 Author: Thomas Groh <[email protected]> Authored: Tue Feb 21 16:31:11 2017 -0800 Committer: Sela <[email protected]> Committed: Wed Feb 22 10:04:33 2017 +0200 ---------------------------------------------------------------------- .../test/java/org/apache/beam/runners/spark/WatermarkTest.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/146ce988/runners/spark/src/test/java/org/apache/beam/runners/spark/WatermarkTest.java ---------------------------------------------------------------------- diff --git a/runners/spark/src/test/java/org/apache/beam/runners/spark/WatermarkTest.java b/runners/spark/src/test/java/org/apache/beam/runners/spark/WatermarkTest.java index e7a5481..0a0abf9 100644 --- a/runners/spark/src/test/java/org/apache/beam/runners/spark/WatermarkTest.java +++ b/runners/spark/src/test/java/org/apache/beam/runners/spark/WatermarkTest.java @@ -38,6 +38,7 @@ import org.apache.beam.sdk.transforms.ParDo; import org.apache.spark.api.java.JavaSparkContext; import org.joda.time.Duration; import org.joda.time.Instant; +import org.junit.Ignore; import org.junit.Rule; import org.junit.Test; import org.junit.rules.ExpectedException; @@ -159,6 +160,9 @@ public class WatermarkTest { } @Test + @Ignore( + "BEAM-1526 - This test is flaky, and is expected to be fixed in " + + "https://github.com/apache/beam/pull/2050";) public void testInDoFn() { // because watermark advances onBatchCompleted. Iterable<Integer> zeroBatch = Collections.emptyList();
