From be0ce57de24a8e2a1941d7ce81089043624dc5c0 Mon Sep 17 00:00:00 2001
From: Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)>
Date: Wed, 15 Dec 2010 18:34:27 -0800
Subject: [PATCH] - Fixed an compilation error due to wrong 'import' of legacy
lzf libraries in DfsBroadcast.scala - Updated to use ning libraries. -
Passes all unit tests
---
src/scala/spark/Broadcast.scala | 2 --
src/scala/spark/DfsBroadcast.scala | 2 +-
2 files changed, 1 insertion(+), 3 deletions(-)
diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala
index 17a530e49f..6b097903de 100644
--- a/src/scala/spark/Broadcast.scala
+++ b/src/scala/spark/Broadcast.scala
@@ -14,8 +14,6 @@ import scala.collection.mutable.Map
import org.apache.hadoop.conf.Configuration
import org.apache.hadoop.fs.{FileSystem, Path, RawLocalFileSystem}
-import com.ning.compress.lzf.{LZFInputStream, LZFOutputStream}
-
@serializable
trait Broadcast[T] {
val uuid = UUID.randomUUID
diff --git a/src/scala/spark/DfsBroadcast.scala b/src/scala/spark/DfsBroadcast.scala
index 3178076916..480d6dd9b1 100644
--- a/src/scala/spark/DfsBroadcast.scala
+++ b/src/scala/spark/DfsBroadcast.scala
@@ -7,7 +7,7 @@ import java.util.UUID
import org.apache.hadoop.conf.Configuration
import org.apache.hadoop.fs.{FileSystem, Path, RawLocalFileSystem}
-import spark.compress.lzf.{LZFInputStream, LZFOutputStream}
+import com.ning.compress.lzf.{LZFInputStream, LZFOutputStream}
@serializable
class DfsBroadcast[T](@transient var value_ : T, isLocal: Boolean)
--
GitLab