You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2018/08/14 22:31:35 UTC

[beam] branch master updated: [BEAM-5070] Disable resumeFromCheckpoint test due to flakiness

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

pabloem 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 c1ab4ec  [BEAM-5070] Disable resumeFromCheckpoint test due to flakiness
c1ab4ec is described below

commit c1ab4ec7ae25ffdf68de5474e6c12cf754b34e2a
Author: Mikhail Gryzykhin <mi...@google.com>
AuthorDate: Tue Aug 14 12:57:04 2018 -0700

    [BEAM-5070] Disable resumeFromCheckpoint test due to flakiness
---
 .../org/apache/beam/sdk/nexmark/sources/UnboundedEventSourceTest.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/sdks/java/nexmark/src/test/java/org/apache/beam/sdk/nexmark/sources/UnboundedEventSourceTest.java b/sdks/java/nexmark/src/test/java/org/apache/beam/sdk/nexmark/sources/UnboundedEventSourceTest.java
index cb0d935..1980ee8 100644
--- a/sdks/java/nexmark/src/test/java/org/apache/beam/sdk/nexmark/sources/UnboundedEventSourceTest.java
+++ b/sdks/java/nexmark/src/test/java/org/apache/beam/sdk/nexmark/sources/UnboundedEventSourceTest.java
@@ -34,6 +34,7 @@ import org.apache.beam.sdk.nexmark.sources.generator.GeneratorCheckpoint;
 import org.apache.beam.sdk.nexmark.sources.generator.GeneratorConfig;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.testing.TestPipeline;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
@@ -78,6 +79,7 @@ public class UnboundedEventSourceTest {
    * Check aggressively checkpointing and resuming a reader gives us exactly the same event stream
    * as reading directly.
    */
+  @Ignore("TODO(BEAM-5070) Test is flaky. Fix before reenabling.")
   @Test
   public void resumeFromCheckpoint() throws IOException {
     Random random = new Random(297);