Repository: spark Updated Branches: refs/heads/master 7db47c463 -> 4c60fd1e8
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/4c60fd1e Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/4c60fd1e Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/4c60fd1e Branch: refs/heads/master Commit: 4c60fd1e8c526278b7e5544d6164050d1aee0338 Parents: 7db47c4 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:06 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/4c60fd1e/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)