Updated Branches: refs/heads/master ef95569f8 -> d5478c2a8
SAMZA-53: Extraneous import breaks compilation. Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/d5478c2a Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/d5478c2a Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/d5478c2a Branch: refs/heads/master Commit: d5478c2a8d3b84d7e6b9104f87b3a6f1379af683 Parents: ef95569 Author: Jakob Glen Homan <[email protected]> Authored: Mon Oct 7 14:26:12 2013 -0700 Committer: Jakob Glen Homan <[email protected]> Committed: Mon Oct 7 14:26:12 2013 -0700 ---------------------------------------------------------------------- .../org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala | 5 ----- 1 file changed, 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/d5478c2a/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 f0c6f8a..9f43585 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 @@ -24,7 +24,6 @@ package org.apache.samza.system.kafka import org.junit.Assert._ import org.junit.Test import kafka.zk.EmbeddedZookeeper -import org.apache.samza.checkpoint.Checkpoint import org.junit.BeforeClass import org.junit.AfterClass import org.apache.samza.util.ClientUtilTopicMetadataStore @@ -39,16 +38,12 @@ import kafka.server.KafkaServer import kafka.producer.Producer import kafka.server.KafkaConfig import kafka.utils.Utils -import org.apache.samza.system.SystemStream import kafka.utils.ZKStringSerializer import scala.collection.JavaConversions._ import kafka.producer.KeyedMessage -import kafka.message.MessageAndMetadata -import scala.collection.mutable.ArrayBuffer import kafka.consumer.Consumer import kafka.consumer.ConsumerConfig import java.util.Properties -import com.sun.xml.internal.xsom.impl.parser.state.group object TestKafkaSystemAdmin { val TOPIC = "input"
