diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala
index 17a530e49f561267703afe45c303ec4bd160acbc..6b097903deeb12a49486f777cae5d980a6575392 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 31780769162cc8bbaea09f54d54e7247d13f480c..480d6dd9b1fe72fae626be6ea91a97bd55723ffc 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)