Repository: incubator-samza Updated Branches: refs/heads/master cb40a5986 -> 811f2897c
http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-kafka/src/test/scala/org/apache/samza/serializers/TestKafkaSerde.scala ---------------------------------------------------------------------- diff --git a/samza-kafka/src/test/scala/org/apache/samza/serializers/TestKafkaSerde.scala b/samza-kafka/src/test/scala/org/apache/samza/serializers/TestKafkaSerde.scala index f6fa6bb..35bf688 100644 --- a/samza-kafka/src/test/scala/org/apache/samza/serializers/TestKafkaSerde.scala +++ b/samza-kafka/src/test/scala/org/apache/samza/serializers/TestKafkaSerde.scala @@ -18,15 +18,17 @@ */ package org.apache.samza.serializers -import org.junit.Assert._ -import org.junit.Test + import kafka.serializer.StringEncoder import kafka.serializer.StringDecoder +import org.junit.Assert._ +import org.junit.Test + class TestKafkaSerde { @Test def testKafkaSerdeShouldWrapEncoderAndDecoders { val serde = new KafkaSerde(new StringEncoder, new StringDecoder) - serde.fromBytes(serde.toBytes("test")).equals("test") + assertEquals("test", serde.fromBytes(serde.toBytes("test"))) } } http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestBrokerProxy.scala ---------------------------------------------------------------------- diff --git a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestBrokerProxy.scala b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestBrokerProxy.scala index 9143e6c..6d01071 100644 --- a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestBrokerProxy.scala +++ b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestBrokerProxy.scala @@ -20,25 +20,27 @@ */ package org.apache.samza.system.kafka +import java.nio.ByteBuffer +import java.util.concurrent.CountDownLatch + +import kafka.api._ +import kafka.api.PartitionOffsetsResponse +import kafka.common.ErrorMapping +import kafka.common.TopicAndPartition +import kafka.consumer.SimpleConsumer +import kafka.message.{MessageSet, Message, MessageAndOffset, ByteBufferMessageSet} + +import org.apache.samza.SamzaException +import org.apache.samza.util.Logging import org.junit._ import org.junit.Assert._ import org.mockito.{Matchers, Mockito} -import scala.collection.JavaConversions._ -import kafka.consumer.SimpleConsumer import org.mockito.Mockito._ import org.mockito.Matchers._ -import kafka.api._ -import kafka.message.{MessageSet, Message, MessageAndOffset, ByteBufferMessageSet} -import kafka.common.TopicAndPartition -import kafka.api.PartitionOffsetsResponse -import java.nio.ByteBuffer -import org.apache.samza.SamzaException -import org.apache.samza.util.Logging -import kafka.common.ErrorMapping import org.mockito.stubbing.Answer import org.mockito.invocation.InvocationOnMock -import java.util.concurrent.CountDownLatch +import scala.collection.JavaConversions._ class TestBrokerProxy extends Logging { val tp2 = new TopicAndPartition("Redbird", 2013) @@ -177,7 +179,7 @@ class TestBrokerProxy extends Logging { Thread.sleep(1000) assertEquals(0, sink.receivedMessages.size) assertTrue(bp.metrics.brokerSkippedFetchRequests(bp.host, bp.port).getCount > 0) - assertTrue(bp.metrics.brokerReads(bp.host, bp.port).getCount == 0) + assertEquals(0, bp.metrics.brokerReads(bp.host, bp.port).getCount) } @Test def brokerProxyThrowsExceptionOnDuplicateTopicPartitions() = { http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestGetOffset.scala ---------------------------------------------------------------------- diff --git a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestGetOffset.scala b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestGetOffset.scala index 6a9ebca..b959348 100644 --- a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestGetOffset.scala +++ b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestGetOffset.scala @@ -19,17 +19,19 @@ package org.apache.samza.system.kafka -import org.junit._ -import org.junit.Assert._ +import java.nio.ByteBuffer + import kafka.api._ import kafka.common.TopicAndPartition -import org.mockito.{ Matchers, Mockito } -import org.mockito.Mockito._ -import org.mockito.Matchers._ import kafka.consumer.SimpleConsumer import kafka.message.Message import kafka.message.ByteBufferMessageSet -import java.nio.ByteBuffer + +import org.junit._ +import org.junit.Assert._ +import org.mockito.{ Matchers, Mockito } +import org.mockito.Mockito._ +import org.mockito.Matchers._ class TestGetOffset { @@ -80,4 +82,4 @@ class TestGetOffset { } } } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala ---------------------------------------------------------------------- diff --git a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala index be1670c..5ceb109 100644 --- a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala +++ b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala @@ -21,32 +21,35 @@ package org.apache.samza.system.kafka -import org.junit.Assert._ -import org.junit.{Test, BeforeClass, AfterClass} -import kafka.zk.EmbeddedZookeeper -import org.apache.samza.util.ClientUtilTopicMetadataStore -import org.I0Itec.zkclient.ZkClient +import java.util.Properties + import kafka.admin.AdminUtils -import org.apache.samza.util.TopicMetadataStore -import org.apache.samza.Partition -import kafka.producer.ProducerConfig -import kafka.utils.TestUtils import kafka.common.ErrorMapping -import kafka.utils.TestZKUtils -import kafka.server.KafkaServer +import kafka.consumer.Consumer +import kafka.consumer.ConsumerConfig +import kafka.producer.KeyedMessage import kafka.producer.Producer +import kafka.producer.ProducerConfig import kafka.server.KafkaConfig +import kafka.server.KafkaServer +import kafka.utils.TestUtils +import kafka.utils.TestZKUtils import kafka.utils.Utils import kafka.utils.ZKStringSerializer -import scala.collection.JavaConversions._ -import kafka.producer.KeyedMessage -import kafka.consumer.Consumer -import kafka.consumer.ConsumerConfig -import java.util.Properties -import org.apache.samza.system.SystemStreamPartition +import kafka.zk.EmbeddedZookeeper + +import org.I0Itec.zkclient.ZkClient +import org.apache.samza.Partition import org.apache.samza.system.SystemStreamMetadata import org.apache.samza.system.SystemStreamMetadata.SystemStreamPartitionMetadata +import org.apache.samza.system.SystemStreamPartition import org.apache.samza.util.ExponentialSleepStrategy +import org.apache.samza.util.ClientUtilTopicMetadataStore +import org.apache.samza.util.TopicMetadataStore +import org.junit.Assert._ +import org.junit.{Test, BeforeClass, AfterClass} + +import scala.collection.JavaConversions._ object TestKafkaSystemAdmin { val TOPIC = "input" http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemConsumer.scala ---------------------------------------------------------------------- diff --git a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemConsumer.scala b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemConsumer.scala index 23e3e35..2c0f803 100644 --- a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemConsumer.scala +++ b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemConsumer.scala @@ -19,15 +19,16 @@ package org.apache.samza.system.kafka -import org.junit.Test -import org.junit.Assert._ -import org.apache.samza.system.SystemStreamPartition -import org.apache.samza.Partition -import kafka.common.TopicAndPartition -import org.apache.samza.util.TopicMetadataStore import kafka.api.TopicMetadata import kafka.api.PartitionMetadata import kafka.cluster.Broker +import kafka.common.TopicAndPartition + +import org.apache.samza.system.SystemStreamPartition +import org.apache.samza.Partition +import org.apache.samza.util.TopicMetadataStore +import org.junit.Test +import org.junit.Assert._ class TestKafkaSystemConsumer { @Test @@ -92,4 +93,4 @@ class TestKafkaSystemConsumer { class MockMetadataStore(var metadata: Map[String, TopicMetadata] = Map()) extends TopicMetadataStore { def getTopicInfo(topics: Set[String]): Map[String, TopicMetadata] = metadata -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemFactory.scala ---------------------------------------------------------------------- diff --git a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemFactory.scala b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemFactory.scala index aba39c0..8067cbf 100644 --- a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemFactory.scala +++ b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemFactory.scala @@ -19,13 +19,14 @@ package org.apache.samza.system.kafka -import scala.collection.JavaConversions._ -import org.junit.Assert._ -import org.junit.Test import org.apache.samza.SamzaException import org.apache.samza.config.MapConfig import org.apache.samza.metrics.MetricsRegistryMap import org.apache.samza.system.SystemStream +import org.junit.Assert._ +import org.junit.Test + +import scala.collection.JavaConversions._ class TestKafkaSystemFactory { @Test @@ -73,13 +74,13 @@ class TestKafkaSystemFactory { "test", config, new MetricsRegistryMap) - assertTrue(producer != null) + assertNotNull(producer) assertTrue(producer.isInstanceOf[KafkaSystemProducer]) producer = producerFactory.getProducer( "test", config, new MetricsRegistryMap) - assertTrue(producer != null) + assertNotNull(producer) assertTrue(producer.isInstanceOf[KafkaSystemProducer]) } } http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemProducer.scala ---------------------------------------------------------------------- diff --git a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemProducer.scala b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemProducer.scala index 3684db5..72b36f7 100644 --- a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemProducer.scala +++ b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemProducer.scala @@ -18,22 +18,26 @@ */ package org.apache.samza.system.kafka -import org.junit.Assert._ -import org.junit.Test -import kafka.producer.Producer -import kafka.producer.async.DefaultEventHandler -import kafka.producer.ProducerPool -import kafka.serializer.Encoder + import java.nio.ByteBuffer -import kafka.producer.ProducerConfig import java.util.Properties -import scala.collection.JavaConversions._ -import kafka.producer.KeyedMessage import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit + +import kafka.producer.KeyedMessage +import kafka.producer.Producer +import kafka.producer.ProducerConfig +import kafka.producer.ProducerPool +import kafka.producer.async.DefaultEventHandler +import kafka.serializer.Encoder + import org.apache.samza.metrics.MetricsRegistryMap import org.apache.samza.system.OutgoingMessageEnvelope import org.apache.samza.system.SystemStream +import org.junit.Assert._ +import org.junit.Test + +import scala.collection.JavaConversions._ class TestKafkaSystemProducer { @@ -137,7 +141,7 @@ class TestKafkaSystemProducer { override def send(messages: KeyedMessage[Object, Object]*) { assertNotNull(messages) assertEquals(1, messages.length) - assertEquals(messages(0).message, "a") + assertEquals("a", messages(0).message) msgsSent += 1 if (msgsSent <= 5) { throw new RuntimeException("Pretend to fail in send") http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestTopicMetadataCache.scala ---------------------------------------------------------------------- diff --git a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestTopicMetadataCache.scala b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestTopicMetadataCache.scala index 9ddcb71..e698d2f 100644 --- a/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestTopicMetadataCache.scala +++ b/samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestTopicMetadataCache.scala @@ -19,15 +19,17 @@ package org.apache.samza.system.kafka -import org.junit.Assert._ -import org.junit.Before -import org.junit.Test +import java.util.concurrent.CountDownLatch +import java.util.concurrent.atomic.{ AtomicBoolean, AtomicInteger } + import kafka.api.TopicMetadata -import org.apache.samza.util.TopicMetadataStore + import org.I0Itec.zkclient.ZkClient -import java.util.concurrent.atomic.{ AtomicBoolean, AtomicInteger } -import java.util.concurrent.CountDownLatch import org.apache.samza.util.Clock +import org.apache.samza.util.TopicMetadataStore +import org.junit.Assert._ +import org.junit.Before +import org.junit.Test class TestTopicMetadataCache { http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-kv-leveldb/src/test/scala/org/apache/samza/storage/kv/TestKeyValueStores.scala ---------------------------------------------------------------------- diff --git a/samza-kv-leveldb/src/test/scala/org/apache/samza/storage/kv/TestKeyValueStores.scala b/samza-kv-leveldb/src/test/scala/org/apache/samza/storage/kv/TestKeyValueStores.scala index 1f09ae5..eefe114 100644 --- a/samza-kv-leveldb/src/test/scala/org/apache/samza/storage/kv/TestKeyValueStores.scala +++ b/samza-kv-leveldb/src/test/scala/org/apache/samza/storage/kv/TestKeyValueStores.scala @@ -22,9 +22,9 @@ package org.apache.samza.storage.kv import java.io.File import java.util.Arrays import java.util.Random -import org.apache.samza.storage.kv.inmemory.InMemoryKeyValueStore -import scala.collection.JavaConversions._ +import org.apache.samza.serializers.Serde +import org.apache.samza.storage.kv.inmemory.InMemoryKeyValueStore import org.iq80.leveldb.Options import org.junit.After import org.junit.Assert._ @@ -33,9 +33,9 @@ import org.junit.Test import org.junit.runner.RunWith import org.junit.runners.Parameterized import org.junit.runners.Parameterized.Parameters -import org.apache.samza.serializers.Serde import org.scalatest.Assertions.intercept +import scala.collection.JavaConversions._ import scala.collection.mutable.ArrayBuffer /** @@ -106,7 +106,7 @@ class TestKeyValueStores(typeOfStore: String, storeConfig: String) { @Test def putAndGet() { store.put(b("k"), b("v")) - assertTrue(Arrays.equals(b("v"), store.get(b("k")))) + assertArrayEquals(b("v"), store.get(b("k"))) } @Test @@ -115,7 +115,7 @@ class TestKeyValueStores(typeOfStore: String, storeConfig: String) { store.put(k, b("v1")) store.put(k, b("v2")) store.put(k, b("v3")) - assertTrue(Arrays.equals(b("v3"), store.get(k))) + assertArrayEquals(b("v3"), store.get(k)) } @Test @@ -179,7 +179,7 @@ class TestKeyValueStores(typeOfStore: String, storeConfig: String) { val a = b("a") assertNull(store.get(a)) store.put(a, a) - assertTrue(Arrays.equals(a, store.get(a))) + assertArrayEquals(a, store.get(a)) store.delete(a) assertNull(store.get(a)) } @@ -190,9 +190,9 @@ class TestKeyValueStores(typeOfStore: String, storeConfig: String) { for (v <- vals) { assertNull(store.get(v)) store.put(v, v) - assertTrue(Arrays.equals(v, store.get(v))) + assertArrayEquals(v, store.get(v)) } - vals.foreach(v => assertTrue(Arrays.equals(v, store.get(v)))) + vals.foreach(v => assertArrayEquals(v, store.get(v))) vals.foreach(v => store.delete(v)) vals.foreach(v => assertNull(store.get(v))) } http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-log4j/src/test/java/org/apache/samza/logging/log4j/TestJmxAppender.java ---------------------------------------------------------------------- diff --git a/samza-log4j/src/test/java/org/apache/samza/logging/log4j/TestJmxAppender.java b/samza-log4j/src/test/java/org/apache/samza/logging/log4j/TestJmxAppender.java index 036d80c..0bdade0 100644 --- a/samza-log4j/src/test/java/org/apache/samza/logging/log4j/TestJmxAppender.java +++ b/samza-log4j/src/test/java/org/apache/samza/logging/log4j/TestJmxAppender.java @@ -19,11 +19,14 @@ package org.apache.samza.logging.log4j; +import static org.junit.Assert.assertEquals; + import java.lang.management.ManagementFactory; import java.rmi.registry.LocateRegistry; import java.util.ArrayList; import java.util.List; import java.util.Iterator; + import javax.management.Attribute; import javax.management.MBeanServer; import javax.management.MBeanServerConnection; @@ -32,13 +35,13 @@ import javax.management.remote.JMXConnectorFactory; import javax.management.remote.JMXConnectorServer; import javax.management.remote.JMXConnectorServerFactory; import javax.management.remote.JMXServiceURL; + import org.apache.log4j.AppenderSkeleton; import org.apache.log4j.Logger; import org.apache.log4j.spi.LoggingEvent; import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; -import static org.junit.Assert.assertEquals; /* * These tests assume that log4j.xml and log4j are both set on the classpath http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-serializers/src/test/scala/org/apache/samza/serializers/TestJsonSerde.scala ---------------------------------------------------------------------- diff --git a/samza-serializers/src/test/scala/org/apache/samza/serializers/TestJsonSerde.scala b/samza-serializers/src/test/scala/org/apache/samza/serializers/TestJsonSerde.scala index e2a153b..6046071 100644 --- a/samza-serializers/src/test/scala/org/apache/samza/serializers/TestJsonSerde.scala +++ b/samza-serializers/src/test/scala/org/apache/samza/serializers/TestJsonSerde.scala @@ -18,8 +18,10 @@ */ package org.apache.samza.serializers + import org.junit.Assert._ import org.junit.Test + import scala.collection.JavaConversions._ class TestJsonSerde { @@ -28,6 +30,6 @@ class TestJsonSerde { val serde = new JsonSerde val obj = new java.util.HashMap[String, Object](Map[String, Object]("hi" -> "bye", "why" -> new java.lang.Integer(2))) val bytes = serde.toBytes(obj) - serde.fromBytes(bytes).equals(obj) + assertEquals(obj, serde.fromBytes(bytes)) } } http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-serializers/src/test/scala/org/apache/samza/serializers/TestMetricsSnapshotSerde.scala ---------------------------------------------------------------------- diff --git a/samza-serializers/src/test/scala/org/apache/samza/serializers/TestMetricsSnapshotSerde.scala b/samza-serializers/src/test/scala/org/apache/samza/serializers/TestMetricsSnapshotSerde.scala index b307334..5bc0be6 100644 --- a/samza-serializers/src/test/scala/org/apache/samza/serializers/TestMetricsSnapshotSerde.scala +++ b/samza-serializers/src/test/scala/org/apache/samza/serializers/TestMetricsSnapshotSerde.scala @@ -18,15 +18,19 @@ */ package org.apache.samza.serializers -import org.junit.Assert._ -import org.junit.Test + +import java.util.HashMap +import java.util.Map + import org.apache.samza.metrics.reporter.MetricsSnapshot import org.apache.samza.metrics.reporter.MetricsHeader import org.apache.samza.metrics.reporter.Metrics -import java.util.HashMap -import java.util.Map +import org.junit.Assert._ +import org.junit.Ignore +import org.junit.Test class TestMetricsSnapshotSerde { + @Ignore @Test def testMetricsSerdeShouldSerializeAndDeserializeAMetric { val header = new MetricsHeader("test", "testjobid", "task", "test", "version", "samzaversion", "host", 1L, 2L) @@ -38,6 +42,6 @@ class TestMetricsSnapshotSerde { val snapshot = new MetricsSnapshot(header, metrics) val serde = new MetricsSnapshotSerde() val bytes = serde.toBytes(snapshot) - serde.fromBytes(bytes).equals(metrics) + assertTrue(serde.fromBytes(bytes).equals(metrics)) } } http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-test/src/test/scala/org/apache/samza/test/integration/TestStatefulTask.scala ---------------------------------------------------------------------- diff --git a/samza-test/src/test/scala/org/apache/samza/test/integration/TestStatefulTask.scala b/samza-test/src/test/scala/org/apache/samza/test/integration/TestStatefulTask.scala index 44ab623..118f5ee 100644 --- a/samza-test/src/test/scala/org/apache/samza/test/integration/TestStatefulTask.scala +++ b/samza-test/src/test/scala/org/apache/samza/test/integration/TestStatefulTask.scala @@ -20,7 +20,9 @@ package org.apache.samza.test.integration import java.util.Properties +import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit + import kafka.admin.AdminUtils import kafka.common.ErrorMapping import kafka.consumer.Consumer @@ -36,12 +38,12 @@ import kafka.utils.TestZKUtils import kafka.utils.Utils import kafka.utils.ZKStringSerializer import kafka.zk.EmbeddedZookeeper + import org.I0Itec.zkclient.ZkClient import org.apache.samza.Partition import org.apache.samza.checkpoint.Checkpoint import org.apache.samza.config.Config import org.apache.samza.job.local.ThreadJobFactory -import java.util.concurrent.CountDownLatch import org.apache.samza.config.MapConfig import org.apache.samza.container.TaskName import org.apache.samza.job.ApplicationStatus @@ -59,6 +61,7 @@ import org.apache.samza.util.ClientUtilTopicMetadataStore import org.apache.samza.util.TopicMetadataStore import org.junit.Assert._ import org.junit.{BeforeClass, AfterClass, Test} + import scala.collection.JavaConversions._ import scala.collection.mutable.ArrayBuffer import scala.collection.mutable.HashMap @@ -254,7 +257,7 @@ class TestStatefulTask { assertEquals("3", messages(2)) assertEquals("2", messages(3)) assertEquals("99", messages(4)) - assertEquals(null, messages(5)) + assertNull(messages(5)) stopJob(job) } @@ -297,14 +300,14 @@ class TestStatefulTask { assertEquals("3", messages(2)) assertEquals("2", messages(3)) assertEquals("99", messages(4)) - assertEquals(null, messages(5)) + assertNull(messages(5)) // From second startup. assertEquals("1", messages(6)) assertEquals("2", messages(7)) assertEquals("3", messages(8)) assertEquals("2", messages(9)) assertEquals("99", messages(10)) - assertEquals(null, messages(11)) + assertNull(messages(11)) // From sending in this method. assertEquals("4", messages(12)) assertEquals("5", messages(13)) http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-test/src/test/scala/org/apache/samza/test/performance/TestSamzaContainerPerformance.scala ---------------------------------------------------------------------- diff --git a/samza-test/src/test/scala/org/apache/samza/test/performance/TestSamzaContainerPerformance.scala b/samza-test/src/test/scala/org/apache/samza/test/performance/TestSamzaContainerPerformance.scala index 1ff898d..d589d76 100644 --- a/samza-test/src/test/scala/org/apache/samza/test/performance/TestSamzaContainerPerformance.scala +++ b/samza-test/src/test/scala/org/apache/samza/test/performance/TestSamzaContainerPerformance.scala @@ -19,19 +19,20 @@ package org.apache.samza.test.performance -import org.apache.samza.job.local.ThreadJobFactory -import org.junit.Test -import org.apache.samza.task.StreamTask -import org.apache.samza.task.TaskCoordinator -import org.apache.samza.task.MessageCollector -import org.apache.samza.system.IncomingMessageEnvelope +import org.apache.samza.config.Config import org.apache.samza.config.MapConfig -import scala.collection.JavaConversions._ import org.apache.samza.job.ShellCommandBuilder +import org.apache.samza.job.local.ThreadJobFactory import org.apache.samza.task.InitableTask +import org.apache.samza.task.MessageCollector +import org.apache.samza.task.StreamTask +import org.apache.samza.task.TaskCoordinator import org.apache.samza.task.TaskContext -import org.apache.samza.config.Config +import org.apache.samza.system.IncomingMessageEnvelope import org.apache.samza.util.Logging +import org.junit.Test + +import scala.collection.JavaConversions._ /** * A simple unit test that drives the TestPerformanceTask. This unit test can http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMaster.scala ---------------------------------------------------------------------- diff --git a/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMaster.scala b/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMaster.scala index 190ce28..7b7d86a 100644 --- a/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMaster.scala +++ b/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMaster.scala @@ -19,14 +19,15 @@ package org.apache.samza.job.yarn -import scala.annotation.elidable -import scala.annotation.elidable.ASSERTION +import TestSamzaAppMasterTaskManager._ import org.apache.hadoop.yarn.api.records.{ Container, ContainerStatus } import org.apache.hadoop.yarn.conf.YarnConfiguration import org.junit.Test +import org.junit.Assert._ -import TestSamzaAppMasterTaskManager._ +import scala.annotation.elidable +import scala.annotation.elidable.ASSERTION class TestSamzaAppMaster { @Test @@ -53,8 +54,8 @@ class TestSamzaAppMaster { } SamzaAppMaster.listeners = List(listener) SamzaAppMaster.run(amClient, SamzaAppMaster.listeners, new YarnConfiguration, 1) - assert(listener.init == 1) - assert(listener.shutdown == 1) + assertEquals(1, listener.init) + assertEquals(1, listener.shutdown) } @Test @@ -78,8 +79,8 @@ class TestSamzaAppMaster { // listener1 will throw an exception in shutdown, and listener2 should still get called SamzaAppMaster.listeners = List(listener1, listener2) SamzaAppMaster.run(amClient, SamzaAppMaster.listeners, new YarnConfiguration, 1) - assert(listener1.shutdown == 1) - assert(listener2.shutdown == 1) + assertEquals(1, listener1.shutdown) + assertEquals(1, listener2.shutdown) } @Test @@ -105,8 +106,8 @@ class TestSamzaAppMaster { thread.start thread.interrupt thread.join - assert(listener.init == 1) - assert(listener.shutdown == 1) + assertEquals(1, listener.init) + assertEquals(1, listener.shutdown) } @Test @@ -127,8 +128,8 @@ class TestSamzaAppMaster { SamzaAppMaster.listeners = List(listener) SamzaAppMaster.run(amClient, SamzaAppMaster.listeners, new YarnConfiguration, 1) // heartbeat may be triggered for more than once - assert(listener.allocated >= 1) - assert(listener.complete >= 1) + assertTrue(listener.allocated >= 1) + assertTrue(listener.complete >= 1) } @Test @@ -145,6 +146,6 @@ class TestSamzaAppMaster { SamzaAppMaster.listeners = List(listener) SamzaAppMaster.run(amClient, SamzaAppMaster.listeners, new YarnConfiguration, 1) // heartbeat may be triggered for more than once - assert(listener.reboot >= 1) + assertTrue(listener.reboot >= 1) } } http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterLifecycle.scala ---------------------------------------------------------------------- diff --git a/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterLifecycle.scala b/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterLifecycle.scala index 3418a4c..6bf6aee 100644 --- a/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterLifecycle.scala +++ b/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterLifecycle.scala @@ -21,9 +21,6 @@ package org.apache.samza.job.yarn import java.nio.ByteBuffer -import scala.annotation.elidable -import scala.annotation.elidable.ASSERTION - import org.apache.hadoop.conf.Configuration import org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse import org.apache.hadoop.yarn.api.records._ @@ -32,9 +29,12 @@ import org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler import org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl import org.apache.hadoop.yarn.util.ConverterUtils import org.apache.samza.SamzaException +import org.mockito.Mockito import org.junit.Assert._ import org.junit.Test -import org.mockito.Mockito + +import scala.annotation.elidable +import scala.annotation.elidable.ASSERTION class TestSamzaAppMasterLifecycle { val amClient = new AMRMClientAsyncImpl[ContainerRequest](1, Mockito.mock(classOf[CallbackHandler])) { @@ -84,8 +84,8 @@ class TestSamzaAppMasterLifecycle { state.rpcPort = 1 val saml = new SamzaAppMasterLifecycle(512, 2, state, amClient) saml.onInit - assert(amClient.host == "test") - assert(amClient.port == 1) + assertEquals("test", amClient.host) + assertEquals(1, amClient.port) assertFalse(saml.shouldShutdown) } @@ -94,7 +94,7 @@ class TestSamzaAppMasterLifecycle { val state = new SamzaAppMasterState(-1, ConverterUtils.toContainerId("container_1350670447861_0003_01_000001"), "", 1, 2) state.status = FinalApplicationStatus.SUCCEEDED new SamzaAppMasterLifecycle(128, 1, state, amClient).onShutdown - assert(amClient.status == FinalApplicationStatus.SUCCEEDED) + assertEquals(FinalApplicationStatus.SUCCEEDED, amClient.status) } @Test @@ -106,7 +106,7 @@ class TestSamzaAppMasterLifecycle { // expected case e: SamzaException => gotException = true } - assert(gotException) + assertTrue(gotException) } @Test http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterService.scala ---------------------------------------------------------------------- diff --git a/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterService.scala b/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterService.scala index d68dbdd..a7ce241 100644 --- a/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterService.scala +++ b/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterService.scala @@ -19,14 +19,16 @@ package org.apache.samza.job.yarn -import scala.collection.JavaConversions._ -import org.apache.samza.config.MapConfig -import org.junit.Assert._ -import org.junit.Test import java.io.BufferedReader import java.net.URL import java.io.InputStreamReader + import org.apache.hadoop.yarn.util.ConverterUtils +import org.apache.samza.config.MapConfig +import org.junit.Assert._ +import org.junit.Test + +import scala.collection.JavaConversions._ class TestSamzaAppMasterService { @Test @@ -36,8 +38,8 @@ class TestSamzaAppMasterService { // start the dashboard service.onInit - assert(state.rpcPort > 0) - assert(state.trackingPort > 0) + assertTrue(state.rpcPort > 0) + assertTrue(state.trackingPort > 0) // check to see if it's running val url = new URL("http://127.0.0.1:%d/am"; format state.rpcPort) @@ -77,8 +79,8 @@ class TestSamzaAppMasterService { // start the dashboard service.onInit - assert(state.rpcPort > 0) - assert(state.trackingPort > 0) + assertTrue(state.rpcPort > 0) + assertTrue(state.trackingPort > 0) // Do a GET Request on the tracking port: This in turn will render index.scaml val url = new URL("http://127.0.0.1:%d/"; format state.trackingPort) http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/811f2897/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterTaskManager.scala ---------------------------------------------------------------------- diff --git a/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterTaskManager.scala b/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterTaskManager.scala index 8cfdbe0..3f3154c 100644 --- a/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterTaskManager.scala +++ b/samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaAppMasterTaskManager.scala @@ -19,8 +19,6 @@ package org.apache.samza.job.yarn -import scala.collection.JavaConversions._ - import org.apache.hadoop.conf.Configuration import org.apache.hadoop.fs.Path import org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse @@ -41,6 +39,8 @@ import org.apache.samza.util.SinglePartitionWithoutOffsetsSystemAdmin import org.apache.samza.util.Util import org.junit.Test +import scala.collection.JavaConversions._ + import TestSamzaAppMasterTaskManager._ object TestSamzaAppMasterTaskManager { @@ -153,7 +153,7 @@ class TestSamzaAppMasterTaskManager { def testAppMasterShouldDefaultToOneContainerIfTaskCountIsNotSpecified { val state = new SamzaAppMasterState(-1, ConverterUtils.toContainerId("container_1350670447861_0003_01_000001"), "", 1, 2) val taskManager = new SamzaAppMasterTaskManager(clock, config, state, null, new YarnConfiguration) - assert(state.taskCount == 1) + assertEquals(1, state.taskCount) } @Test @@ -161,13 +161,13 @@ class TestSamzaAppMasterTaskManager { val state = new SamzaAppMasterState(-1, ConverterUtils.toContainerId("container_1350670447861_0003_01_000001"), "", 1, 2) val taskManager = new SamzaAppMasterTaskManager(clock, config, state, null, new YarnConfiguration) - assert(taskManager.shouldShutdown == false) + assertFalse(taskManager.shouldShutdown) taskManager.onContainerCompleted(getContainerStatus(state.containerId, 0, "")) - assert(taskManager.shouldShutdown == true) - assert(state.completedTasks == 1) - assert(state.taskCount == 1) - assert(state.jobHealthy) - assert(state.status.equals(FinalApplicationStatus.SUCCEEDED)) + assertTrue(taskManager.shouldShutdown) + assertEquals(1, state.completedTasks) + assertEquals(1, state.taskCount) + assertTrue(state.jobHealthy) + assertEquals(FinalApplicationStatus.SUCCEEDED, state.status) } @Test @@ -180,12 +180,12 @@ class TestSamzaAppMasterTaskManager { } } - assert(taskManager.shouldShutdown == false) + assertFalse(taskManager.shouldShutdown) val container2 = ConverterUtils.toContainerId("container_1350670447861_0003_01_000002") taskManager.onInit taskManager.onContainerAllocated(getContainer(container2)) taskManager.onContainerCompleted(getContainerStatus(container2, 1, "expecting a failure here")) - assert(taskManager.shouldShutdown == false) + assertFalse(taskManager.shouldShutdown) assertFalse(state.jobHealthy) // 2. First is from onInit, second is from onContainerCompleted, since it failed. @@ -195,13 +195,13 @@ class TestSamzaAppMasterTaskManager { // 3. Now trigger an AM shutdown since our retry count is 1, and we're failing twice taskManager.onContainerAllocated(getContainer(container2)) - assert(state.jobHealthy) + assertTrue(state.jobHealthy) taskManager.onContainerCompleted(getContainerStatus(container2, 1, "expecting a failure here")) assertEquals(2, amClient.getClient.requests.size) assertEquals(0, amClient.getClient.getRelease.size) assertFalse(state.jobHealthy) assertTrue(taskManager.shouldShutdown) - assert(state.status.equals(FinalApplicationStatus.FAILED)) + assertEquals(FinalApplicationStatus.FAILED, state.status) } @Test @@ -224,60 +224,60 @@ class TestSamzaAppMasterTaskManager { val container2 = ConverterUtils.toContainerId("container_1350670447861_0003_01_000002") val container3 = ConverterUtils.toContainerId("container_1350670447861_0003_01_000003") - assert(taskManager.shouldShutdown == false) + assertFalse(taskManager.shouldShutdown) taskManager.onInit - assert(taskManager.shouldShutdown == false) - assert(amClient.getClient.requests.size == 1) - assert(amClient.getClient.getRelease.size == 0) + assertFalse(taskManager.shouldShutdown) + assertEquals(1, amClient.getClient.requests.size) + assertEquals(0, amClient.getClient.getRelease.size) // allocate container 2 taskManager.onContainerAllocated(getContainer(container2)) - assert(state.neededContainers == 0) - assert(state.runningTasks.size == 1) - assert(state.taskToTaskNames.size == 1) - assert(state.unclaimedTasks.size == 0) - assert(containersRequested == 1) - assert(containersStarted == 1) + assertEquals(0, state.neededContainers) + assertEquals(1, state.runningTasks.size) + assertEquals(1, state.taskToTaskNames.size) + assertEquals(0, state.unclaimedTasks.size) + assertEquals(1, containersRequested) + assertEquals(1, containersStarted) // allocate an extra container, which the AM doesn't need, and should be released taskManager.onContainerAllocated(getContainer(container3)) - assert(state.neededContainers == 0) - assert(state.runningTasks.size == 1) - assert(state.taskToTaskNames.size == 1) - assert(state.unclaimedTasks.size == 0) - assert(amClient.getClient.requests.size == 1) - assert(amClient.getClient.getRelease.size == 1) - assert(amClient.getClient.getRelease.head.equals(container3)) + assertEquals(0, state.neededContainers) + assertEquals(1, state.runningTasks.size) + assertEquals(1, state.taskToTaskNames.size) + assertEquals(0, state.unclaimedTasks.size) + assertEquals(1, amClient.getClient.requests.size) + assertEquals(1, amClient.getClient.getRelease.size) + assertEquals(container3, amClient.getClient.getRelease.head) // reset the helper state, so we can make sure that releasing the container (next step) doesn't request more resources amClient.getClient.requests = List() amClient.getClient.resetRelease // now release the container, and make sure the AM doesn't ask for more - assert(taskManager.shouldShutdown == false) + assertFalse(taskManager.shouldShutdown) taskManager.onContainerCompleted(getContainerStatus(container3, -100, "pretend the container was released")) - assert(taskManager.shouldShutdown == false) - assert(state.neededContainers == 0) - assert(state.runningTasks.size == 1) - assert(state.taskToTaskNames.size == 1) - assert(state.unclaimedTasks.size == 0) - assert(amClient.getClient.requests.size == 0) - assert(amClient.getClient.getRelease.size == 0) + assertFalse(taskManager.shouldShutdown) + assertEquals(0, state.neededContainers) + assertEquals(1, state.runningTasks.size) + assertEquals(1, state.taskToTaskNames.size) + assertEquals(0, state.unclaimedTasks.size) + assertEquals(0, amClient.getClient.requests.size) + assertEquals(0, amClient.getClient.getRelease.size) // pretend container 2 is released due to an NM failure, and make sure that the AM requests a new container - assert(taskManager.shouldShutdown == false) + assertFalse(taskManager.shouldShutdown) taskManager.onContainerCompleted(getContainerStatus(container2, -100, "pretend the container was 'lost' due to an NM failure")) - assert(taskManager.shouldShutdown == false) - assert(state.jobHealthy == false) - assert(amClient.getClient.requests.size == 1) - assert(amClient.getClient.getRelease.size == 0) + assertFalse(taskManager.shouldShutdown) + assertFalse(state.jobHealthy) + assertEquals(1, amClient.getClient.requests.size) + assertEquals(0, amClient.getClient.getRelease.size) taskManager.onContainerAllocated(getContainer(container2)) - assert(state.neededContainers == 0) - assert(state.jobHealthy) - assert(state.runningTasks.size == 1) - assert(state.taskToTaskNames.size == 1) - assert(state.unclaimedTasks.size == 0) + assertEquals(0, state.neededContainers) + assertTrue(state.jobHealthy) + assertEquals(1, state.runningTasks.size) + assertEquals(1, state.taskToTaskNames.size) + assertEquals(0, state.unclaimedTasks.size) } @Test @@ -297,57 +297,57 @@ class TestSamzaAppMasterTaskManager { val container2 = ConverterUtils.toContainerId("container_1350670447861_0003_01_000002") val container3 = ConverterUtils.toContainerId("container_1350670447861_0003_01_000003") - assert(taskManager.shouldShutdown == false) + assertFalse(taskManager.shouldShutdown) taskManager.onInit - assert(taskManager.shouldShutdown == false) - assert(amClient.getClient.requests.size == 2) - assert(amClient.getClient.getRelease.size == 0) + assertFalse(taskManager.shouldShutdown) + assertEquals(2, amClient.getClient.requests.size) + assertEquals(0, amClient.getClient.getRelease.size) taskManager.onContainerAllocated(getContainer(container2)) - assert(state.neededContainers == 1) - assert(state.runningTasks.size == 1) - assert(state.taskToTaskNames.size == 1) - assert(state.unclaimedTasks.size == 1) - assert(containersStarted == 1) + assertEquals(1, state.neededContainers) + assertEquals(1, state.runningTasks.size) + assertEquals(1, state.taskToTaskNames.size) + assertEquals(1, state.unclaimedTasks.size) + assertEquals(1, containersStarted) taskManager.onContainerAllocated(getContainer(container3)) - assert(state.neededContainers == 0) - assert(state.runningTasks.size == 2) - assert(state.taskToTaskNames.size == 2) - assert(state.unclaimedTasks.size == 0) - assert(containersStarted == 2) + assertEquals(0, state.neededContainers) + assertEquals(2, state.runningTasks.size) + assertEquals(2, state.taskToTaskNames.size) + assertEquals(0, state.unclaimedTasks.size) + assertEquals(2, containersStarted) // container2 finishes successfully taskManager.onContainerCompleted(getContainerStatus(container2, 0, "")) - assert(state.neededContainers == 0) - assert(state.runningTasks.size == 1) - assert(state.taskToTaskNames.size == 1) - assert(state.unclaimedTasks.size == 0) - assert(state.completedTasks == 1) + assertEquals(0, state.neededContainers) + assertEquals(1, state.runningTasks.size) + assertEquals(1, state.taskToTaskNames.size) + assertEquals(0, state.unclaimedTasks.size) + assertEquals(1, state.completedTasks) // container3 fails taskManager.onContainerCompleted(getContainerStatus(container3, 1, "expected failure here")) - assert(state.neededContainers == 1) - assert(state.runningTasks.size == 0) - assert(state.taskToTaskNames.size == 0) - assert(state.unclaimedTasks.size == 1) - assert(state.completedTasks == 1) - assert(taskManager.shouldShutdown == false) + assertEquals(1, state.neededContainers) + assertEquals(0, state.runningTasks.size) + assertEquals(0, state.taskToTaskNames.size) + assertEquals(1, state.unclaimedTasks.size) + assertEquals(1, state.completedTasks) + assertFalse(taskManager.shouldShutdown) // container3 is re-allocated taskManager.onContainerAllocated(getContainer(container3)) - assert(state.neededContainers == 0) - assert(state.runningTasks.size == 1) - assert(state.taskToTaskNames.size == 1) - assert(state.unclaimedTasks.size == 0) - assert(containersStarted == 3) + assertEquals(0, state.neededContainers) + assertEquals(1, state.runningTasks.size) + assertEquals(1, state.taskToTaskNames.size) + assertEquals(0, state.unclaimedTasks.size) + assertEquals(3, containersStarted) // container3 finishes sucecssfully taskManager.onContainerCompleted(getContainerStatus(container3, 0, "")) - assert(state.neededContainers == 0) - assert(state.runningTasks.size == 0) - assert(state.taskToTaskNames.size == 0) - assert(state.unclaimedTasks.size == 0) - assert(state.completedTasks == 2) - assert(taskManager.shouldShutdown == true) + assertEquals(0, state.neededContainers) + assertEquals(0, state.runningTasks.size) + assertEquals(0, state.taskToTaskNames.size) + assertEquals(0, state.unclaimedTasks.size) + assertEquals(2, state.completedTasks) + assertTrue(taskManager.shouldShutdown) } @Test @@ -369,32 +369,32 @@ class TestSamzaAppMasterTaskManager { val container2 = ConverterUtils.toContainerId("container_1350670447861_0003_01_000002") val container3 = ConverterUtils.toContainerId("container_1350670447861_0003_01_000003") - assert(taskManager.shouldShutdown == false) + assertFalse(taskManager.shouldShutdown) taskManager.onInit - assert(taskManager.shouldShutdown == false) - assert(amClient.getClient.requests.size == 1) - assert(amClient.getClient.getRelease.size == 0) - assert(state.neededContainers == 1) - assert(state.runningTasks.size == 0) - assert(state.taskToTaskNames.size == 0) - assert(state.unclaimedTasks.size == 1) + assertFalse(taskManager.shouldShutdown) + assertEquals(1, amClient.getClient.requests.size) + assertEquals(0, amClient.getClient.getRelease.size) + assertEquals(1, state.neededContainers) + assertEquals(0, state.runningTasks.size) + assertEquals(0, state.taskToTaskNames.size) + assertEquals(1, state.unclaimedTasks.size) taskManager.onContainerAllocated(getContainer(container2)) - assert(state.neededContainers == 0) - assert(state.runningTasks.size == 1) - assert(state.taskToTaskNames.size == 1) - assert(state.unclaimedTasks.size == 0) - assert(containersRequested == 1) - assert(containersStarted == 1) + assertEquals(0, state.neededContainers) + assertEquals(1, state.runningTasks.size) + assertEquals(1, state.taskToTaskNames.size) + assertEquals(0, state.unclaimedTasks.size) + assertEquals(1, containersRequested) + assertEquals(1, containersStarted) taskManager.onContainerAllocated(getContainer(container3)) - assert(state.neededContainers == 0) - assert(state.runningTasks.size == 1) - assert(state.taskToTaskNames.size == 1) - assert(state.unclaimedTasks.size == 0) - assert(containersRequested == 1) - assert(containersStarted == 1) - assert(amClient.getClient.requests.size == 1) - assert(amClient.getClient.getRelease.size == 1) - assert(amClient.getClient.getRelease.head.equals(container3)) + assertEquals(0, state.neededContainers) + assertEquals(1, state.runningTasks.size) + assertEquals(1, state.taskToTaskNames.size) + assertEquals(0, state.unclaimedTasks.size) + assertEquals(1, containersRequested) + assertEquals(1, containersStarted) + assertEquals(1, amClient.getClient.requests.size) + assertEquals(1, amClient.getClient.getRelease.size) + assertTrue(amClient.getClient.getRelease.head.equals(container3)) } val clock = () => System.currentTimeMillis
