Repository: samza Updated Branches: refs/heads/master 1b9391b9e -> c93dd8f60
SAMZA-1463 disable some flaky tests on hdfs system disable some flaky tests on hdfs system until future investigation Author: Hai Lu <[email protected]> Reviewers: Xinyu Liu <[email protected]> Closes #329 from lhaiesp/master Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/c93dd8f6 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/c93dd8f6 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/c93dd8f6 Branch: refs/heads/master Commit: c93dd8f60c4622e30cb2515ac63796f056a05350 Parents: 1b9391b Author: Hai Lu <[email protected]> Authored: Mon Oct 16 11:26:45 2017 -0700 Committer: Xinyu Liu <[email protected]> Committed: Mon Oct 16 11:26:45 2017 -0700 ---------------------------------------------------------------------- .../org/apache/samza/system/hdfs/TestHdfsSystemConsumer.java | 3 ++- .../samza/system/hdfs/TestHdfsSystemProducerTestSuite.scala | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/c93dd8f6/samza-hdfs/src/test/java/org/apache/samza/system/hdfs/TestHdfsSystemConsumer.java ---------------------------------------------------------------------- diff --git a/samza-hdfs/src/test/java/org/apache/samza/system/hdfs/TestHdfsSystemConsumer.java b/samza-hdfs/src/test/java/org/apache/samza/system/hdfs/TestHdfsSystemConsumer.java index 396b06b..481988f 100644 --- a/samza-hdfs/src/test/java/org/apache/samza/system/hdfs/TestHdfsSystemConsumer.java +++ b/samza-hdfs/src/test/java/org/apache/samza/system/hdfs/TestHdfsSystemConsumer.java @@ -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(); http://git-wip-us.apache.org/repos/asf/samza/blob/c93dd8f6/samza-hdfs/src/test/scala/org/apache/samza/system/hdfs/TestHdfsSystemProducerTestSuite.scala ---------------------------------------------------------------------- diff --git a/samza-hdfs/src/test/scala/org/apache/samza/system/hdfs/TestHdfsSystemProducerTestSuite.scala b/samza-hdfs/src/test/scala/org/apache/samza/system/hdfs/TestHdfsSystemProducerTestSuite.scala index db7036a..8bea0bc 100644 --- a/samza-hdfs/src/test/scala/org/apache/samza/system/hdfs/TestHdfsSystemProducerTestSuite.scala +++ b/samza-hdfs/src/test/scala/org/apache/samza/system/hdfs/TestHdfsSystemProducerTestSuite.scala @@ -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._
