Skip to content
Snippets Groups Projects
Commit 4c60fd1e authored by Patrick Wendell's avatar Patrick Wendell
Browse files

MINOR: Removing dead code.

Meant to do this when patching up the last merge.
parent 7db47c46
No related branches found
No related tags found
No related merge requests found
...@@ -57,7 +57,6 @@ private[spark] object ShuffleMapTask { ...@@ -57,7 +57,6 @@ private[spark] object ShuffleMapTask {
} }
def deserializeInfo(stageId: Int, bytes: Array[Byte]): (RDD[_], ShuffleDependency[_,_]) = { def deserializeInfo(stageId: Int, bytes: Array[Byte]): (RDD[_], ShuffleDependency[_,_]) = {
val loader = Thread.currentThread.getContextClassLoader
val in = new GZIPInputStream(new ByteArrayInputStream(bytes)) val in = new GZIPInputStream(new ByteArrayInputStream(bytes))
val ser = SparkEnv.get.closureSerializer.newInstance() val ser = SparkEnv.get.closureSerializer.newInstance()
val objIn = ser.deserializeStream(in) val objIn = ser.deserializeStream(in)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment