SAMZA-1463 disable some flaky tests on hdfs system
authorHai Lu <halu@linkedin.com>
Mon, 16 Oct 2017 18:26:45 +0000 (11:26 -0700)
committerXinyu Liu <xiliu@xiliu-ld1.linkedin.biz>
Mon, 16 Oct 2017 18:26:45 +0000 (11:26 -0700)
disable some flaky tests on hdfs system until future investigation

Author: Hai Lu <halu@linkedin.com>

Reviewers: Xinyu Liu <xinyuliu.us@gmail.com>

Closes #329 from lhaiesp/master

samza-hdfs/src/test/java/org/apache/samza/system/hdfs/TestHdfsSystemConsumer.java
samza-hdfs/src/test/scala/org/apache/samza/system/hdfs/TestHdfsSystemProducerTestSuite.scala

index 396b06b..481988f 100644 (file)
@@ -40,6 +40,7 @@ import org.apache.samza.system.SystemStreamPartition;
 import org.apache.samza.system.hdfs.reader.TestAvroFileHdfsReader;
 import org.apache.samza.util.NoOpMetricsRegistry;
 import org.junit.Assert;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import com.google.common.util.concurrent.UncheckedExecutionException;
@@ -77,7 +78,7 @@ public class TestHdfsSystemConsumer {
    * partitioner, system consumer, and so on, making sure the basic functionality
    * works as expected.
    */
-  @Test
+  @Ignore
   public void testHdfsSystemConsumerE2E() throws Exception {
     Config config = generateDefaultConfig();
     HdfsSystemFactory systemFactory = new HdfsSystemFactory();
index db7036a..8bea0bc 100644 (file)
@@ -38,7 +38,7 @@ import org.apache.samza.system.hdfs.HdfsConfig._
 import org.apache.samza.system.{OutgoingMessageEnvelope, SystemStream}
 import org.apache.samza.util.Logging
 import org.junit.Assert._
-import org.junit.{AfterClass, Test}
+import org.junit.{AfterClass, Ignore, Test}
 
 
 object TestHdfsSystemProducerTestSuite {
@@ -101,7 +101,7 @@ object TestHdfsSystemProducerTestSuite {
 
 }
 
-
+@Ignore
 class TestHdfsSystemProducerTestSuite extends Logging {
   import org.apache.samza.system.hdfs.TestHdfsSystemProducerTestSuite._