remove the temporary fix

davies · davies · commit 1245eb7df252 · 2014-09-11T17:12:54.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/JobProgressListener.scala b/core/src/main/scala/org/apache/spark/ui/jobs/JobProgressListener.scala
@@ -242,8 +242,7 @@ class JobProgressListener(conf: SparkConf) extends SparkListener with Logging {
             t.taskMetrics)
 
           // Overwrite task metrics
-          // FIXME: deepcopy the metrics, or they will be the same object in local mode
-          t.taskMetrics = Some(scala.util.Marshal.load[TaskMetrics](scala.util.Marshal.dump(taskMetrics)))
+          t.taskMetrics = Some(taskMetrics)
         }
       }
     }

Original file line number	Diff line number	Diff line change
`@@ -242,8 +242,7 @@ class JobProgressListener(conf: SparkConf) extends SparkListener with Logging {`
`242`	`242`	`t.taskMetrics)`
`243`	`243`
`244`	`244`	`// Overwrite task metrics`
`245`		`- // FIXME: deepcopy the metrics, or they will be the same object in local mode`
`246`		`- t.taskMetrics = Some(scala.util.Marshal.load[TaskMetrics](scala.util.Marshal.dump(taskMetrics)))`
	`245`	`+ t.taskMetrics = Some(taskMetrics)`
`247`	`246`	`}`
`248`	`247`	`}`
`249`	`248`	`}`