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);