From ad06b0fb09a57897c3917bb4dd4f258ed8960295 Mon Sep 17 00:00:00 2001 From: Andrew Pilloud Date: Thu, 8 Mar 2018 16:02:26 -0800 Subject: [PATCH] [Nexmark] Sickbay query 6 --- .../java/org/apache/beam/sdk/nexmark/queries/QueryTest.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/sdks/java/nexmark/src/test/java/org/apache/beam/sdk/nexmark/queries/QueryTest.java b/sdks/java/nexmark/src/test/java/org/apache/beam/sdk/nexmark/queries/QueryTest.java index 937a727819ce..07e68f18bcb1 100644 --- a/sdks/java/nexmark/src/test/java/org/apache/beam/sdk/nexmark/queries/QueryTest.java +++ b/sdks/java/nexmark/src/test/java/org/apache/beam/sdk/nexmark/queries/QueryTest.java @@ -34,6 +34,7 @@ import org.apache.beam.sdk.testing.UsesTimersInParDo; import org.apache.beam.sdk.values.PCollection; import org.apache.beam.sdk.values.TimestampedValue; +import org.junit.Ignore; import org.junit.Rule; import org.junit.Test; import org.junit.experimental.categories.Category; @@ -205,12 +206,14 @@ public void sqlQuery5MatchesModelStreaming() { new Query5Model(CONFIG), true); } + @Ignore("https://issues.apache.org/jira/browse/BEAM-3816") @Test @Category(NeedsRunner.class) public void query6MatchesModelBatch() { queryMatchesModel("Query6TestBatch", new Query6(CONFIG), new Query6Model(CONFIG), false); } + @Ignore("https://issues.apache.org/jira/browse/BEAM-3816") @Test @Category(NeedsRunner.class) public void query6MatchesModelStreaming() {