Merge pull request #15 from ryan-williams/ser

dedupe serializer initialization
hammerlab · Apr 7, 2017 · 45d6cdd · 45d6cdd
2 parents db94da8 + 4405cdf
commit 45d6cdd
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/build.sbt b/build.sbt
@@ -1,6 +1,6 @@
 name := "spark-tests"
 
-version := "1.3.4"
+version := "1.3.5"
 
 libraryDependencies ++= Seq(
   libs.value('paths),

diff --git a/project/plugins.sbt b/project/plugins.sbt
@@ -1 +1 @@
-addSbtPlugin("org.hammerlab" % "sbt-parent" % "1.7.2")
+addSbtPlugin("org.hammerlab" % "sbt-parent" % "1.7.6")
diff --git a/src/main/scala/org/hammerlab/spark/test/suite/SparkSerialization.scala b/src/main/scala/org/hammerlab/spark/test/suite/SparkSerialization.scala
@@ -9,9 +9,9 @@ import org.apache.spark.SparkEnv
  * Mix-in that exposes a Spark [[org.apache.spark.serializer.Serializer]] instance.
  */
 trait SparkSerialization {
-  self: SharedSparkContext =>
+  self: SharedSparkContext ⇒
 
-  private def serializer = SparkEnv.get.serializer.newInstance()
+  private lazy val serializer = SparkEnv.get.serializer.newInstance()
 
   def serialize(item: Any): ByteBuffer = serializer.serialize(item)
   def deserialize[T](bytes: ByteBuffer): T = serializer.deserialize(bytes)