aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorDmitriy Lyubimov <dlyubimov@apache.org>2013-07-22 14:48:46 -0700
committerDmitriy Lyubimov <dlyubimov@apache.org>2013-07-22 14:48:46 -0700
commit8ca0c319441c7beddead4dc5b4bd2a1c3e2141e8 (patch)
treee1a6ebfeb1cde1945891e0c85aa12b8ec9baacaa /core
parentb4b230e6067d9a8290b79fe56bbfdea3fb12fdbb (diff)
downloadspark-8ca0c319441c7beddead4dc5b4bd2a1c3e2141e8.tar.gz
spark-8ca0c319441c7beddead4dc5b4bd2a1c3e2141e8.tar.bz2
spark-8ca0c319441c7beddead4dc5b4bd2a1c3e2141e8.zip
removing non-pertinent comment
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/spark/scheduler/TaskResult.scala2
1 files changed, 0 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/scheduler/TaskResult.scala b/core/src/main/scala/spark/scheduler/TaskResult.scala
index 0b459ea600..e14d41249b 100644
--- a/core/src/main/scala/spark/scheduler/TaskResult.scala
+++ b/core/src/main/scala/spark/scheduler/TaskResult.scala
@@ -38,8 +38,6 @@ class TaskResult[T](var value: T, var accumUpdates: Map[Long, Any], var metrics:
override def readExternal(in: ObjectInput) {
- //this doesn't work since SparkEnv.get == null
- // in this context
val objectSer = SparkEnv.get.serializer.newInstance()
val blen = in.readInt()