Repository: spark Updated Branches: refs/heads/branch-1.0 5c8e8de99 -> 1d56cd544
MINOR: Removing dead code. Meant to do this when patching up the last merge. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/1d56cd54 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/1d56cd54 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/1d56cd54 Branch: refs/heads/branch-1.0 Commit: 1d56cd544efce0f8fc36419a5d183f9e44e99957 Parents: 5c8e8de Author: Patrick Wendell <pwend...@gmail.com> Authored: Thu May 8 22:33:06 2014 -0700 Committer: Patrick Wendell <pwend...@gmail.com> Committed: Thu May 8 22:33:45 2014 -0700 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/scheduler/ShuffleMapTask.scala | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/1d56cd54/core/src/main/scala/org/apache/spark/scheduler/ShuffleMapTask.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/scheduler/ShuffleMapTask.scala b/core/src/main/scala/org/apache/spark/scheduler/ShuffleMapTask.scala index 9ba586f..ed0f56f 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/ShuffleMapTask.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/ShuffleMapTask.scala @@ -57,7 +57,6 @@ private[spark] object ShuffleMapTask { } def deserializeInfo(stageId: Int, bytes: Array[Byte]): (RDD[_], ShuffleDependency[_,_]) = { - val loader = Thread.currentThread.getContextClassLoader val in = new GZIPInputStream(new ByteArrayInputStream(bytes)) val ser = SparkEnv.get.closureSerializer.newInstance() val objIn = ser.deserializeStream(in)