You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by at...@apache.org on 2020/01/15 23:36:33 UTC

[samza] branch master updated: Disable Flaky Tests

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

atoomula pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/master by this push:
     new 22f4747  Disable Flaky Tests
     new 842d259  Merge pull request #1253 from abhishekshivanna/rc
22f4747 is described below

commit 22f47477c3f42b6c0a6434bf05755bab845a3d69
Author: Abhishek Shivanna <as...@linkedin.com>
AuthorDate: Wed Jan 15 14:14:53 2020 -0800

    Disable Flaky Tests
---
 .../test/java/org/apache/samza/test/samzasql/TestSamzaSqlEndToEnd.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/samza-test/src/test/java/org/apache/samza/test/samzasql/TestSamzaSqlEndToEnd.java b/samza-test/src/test/java/org/apache/samza/test/samzasql/TestSamzaSqlEndToEnd.java
index 26ba0ec..d46d3b1 100644
--- a/samza-test/src/test/java/org/apache/samza/test/samzasql/TestSamzaSqlEndToEnd.java
+++ b/samza-test/src/test/java/org/apache/samza/test/samzasql/TestSamzaSqlEndToEnd.java
@@ -102,6 +102,7 @@ public class TestSamzaSqlEndToEnd extends SamzaSqlIntegrationTestHarness {
     Assert.assertEquals(numMessages, outMessages.size());
   }
 
+  @Ignore
   @Test
   public void testEndToEndDisableSystemMessages() throws SamzaSqlValidatorException {
     int numMessages = 20;
@@ -258,6 +259,7 @@ public class TestSamzaSqlEndToEnd extends SamzaSqlIntegrationTestHarness {
     Assert.assertTrue(IntStream.range(0, numMessages).boxed().collect(Collectors.toList()).equals(new ArrayList<>(outMessagesSet)));
   }
 
+  @Ignore
   @Test
   public void testEndToEndFanOut() throws SamzaSqlValidatorException {
     int numMessages = 20;
@@ -760,6 +762,7 @@ public class TestSamzaSqlEndToEnd extends SamzaSqlIntegrationTestHarness {
     Assert.assertEquals(expectedOutMessages, outMessages);
   }
 
+  @Ignore
   @Test
   public void testEndToEndStreamTableJoinWithSubQuery() throws Exception {
     int numMessages = 20;