diff options
author | Prashant Sharma <prashant.s@imaginea.com> | 2013-12-10 11:34:10 +0530 |
---|---|---|
committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-12-10 11:47:16 +0530 |
commit | 17db6a9041d5e83d7b6fe47f9c36758d0613fcd6 (patch) | |
tree | 6c99fe68332d7bec882be2fd5e50347c3fb3c134 /streaming | |
parent | c1201f47e0d44e92da42adb23d27f60d9d494642 (diff) | |
download | spark-17db6a9041d5e83d7b6fe47f9c36758d0613fcd6.tar.gz spark-17db6a9041d5e83d7b6fe47f9c36758d0613fcd6.tar.bz2 spark-17db6a9041d5e83d7b6fe47f9c36758d0613fcd6.zip |
Style fixes and addressed review comments at #221
Diffstat (limited to 'streaming')
-rw-r--r-- | streaming/pom.xml | 16 | ||||
-rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/receivers/ZeroMQReceiver.scala | 4 |
2 files changed, 10 insertions, 10 deletions
diff --git a/streaming/pom.xml b/streaming/pom.xml index ff95591b9f..298bc83161 100644 --- a/streaming/pom.xml +++ b/streaming/pom.xml @@ -48,7 +48,7 @@ <dependencies> <dependency> <groupId>org.apache.spark</groupId> - <artifactId>spark-core_${scala-short.version}</artifactId> + <artifactId>spark-core_2.10</artifactId> <version>${project.version}</version> </dependency> <dependency> @@ -61,8 +61,8 @@ <version>1.9.11</version> </dependency> <dependency> - <groupId>org.apache.kafka</groupId> - <artifactId>kafka_2.9.2</artifactId> + <groupId>com.sksamuel.kafka</groupId> + <artifactId>kafka_2.10</artifactId> <version>0.8.0-beta1</version> <exclusions> <exclusion> @@ -111,7 +111,7 @@ </dependency> <dependency> <groupId>com.typesafe.akka</groupId> - <artifactId>akka-zeromq_${scala-short.version}</artifactId> + <artifactId>akka-zeromq_2.10</artifactId> <version>${akka.version}</version> <exclusions> <exclusion> @@ -122,12 +122,12 @@ </dependency> <dependency> <groupId>org.scalatest</groupId> - <artifactId>scalatest_${scala-short.version}</artifactId> + <artifactId>scalatest_2.10</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.scalacheck</groupId> - <artifactId>scalacheck_${scala-short.version}</artifactId> + <artifactId>scalacheck_2.10</artifactId> <scope>test</scope> </dependency> <dependency> @@ -151,8 +151,8 @@ </dependency> </dependencies> <build> - <outputDirectory>target/scala-${scala-short.version}/classes</outputDirectory> - <testOutputDirectory>target/scala-${scala-short.version}/test-classes</testOutputDirectory> + <outputDirectory>target/scala-2.10/classes</outputDirectory> + <testOutputDirectory>target/scala-2.10/test-classes</testOutputDirectory> <plugins> <plugin> <groupId>org.scalatest</groupId> diff --git a/streaming/src/main/scala/org/apache/spark/streaming/receivers/ZeroMQReceiver.scala b/streaming/src/main/scala/org/apache/spark/streaming/receivers/ZeroMQReceiver.scala index ce8c56fa8a..f164d516b0 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/receivers/ZeroMQReceiver.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/receivers/ZeroMQReceiver.scala @@ -17,14 +17,14 @@ package org.apache.spark.streaming.receivers +import scala.reflect.ClassTag + import akka.actor.Actor import akka.util.ByteString import akka.zeromq._ import org.apache.spark.Logging -import scala.reflect.ClassTag - /** * A receiver to subscribe to ZeroMQ stream. */ |