Maintain Serializable API compatibility by reverting back to java.io.Serializable for Broadcast and Accumulator.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/1b5623fd Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/1b5623fd Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/1b5623fd Branch: refs/heads/master Commit: 1b5623fd0bd716d3c556371caabbf94abcc6fb8d Parents: 55db774 Author: Reynold Xin <[email protected]> Authored: Tue Jan 14 11:30:59 2014 -0800 Committer: Reynold Xin <[email protected]> Committed: Tue Jan 14 11:30:59 2014 -0800 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/Accumulators.scala | 2 +- core/src/main/scala/org/apache/spark/broadcast/Broadcast.scala | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/1b5623fd/core/src/main/scala/org/apache/spark/Accumulators.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/Accumulators.scala b/core/src/main/scala/org/apache/spark/Accumulators.scala index fe1537a..df01b2e 100644 --- a/core/src/main/scala/org/apache/spark/Accumulators.scala +++ b/core/src/main/scala/org/apache/spark/Accumulators.scala @@ -17,7 +17,7 @@ package org.apache.spark -import java.io.ObjectInputStream +import java.io.{ObjectInputStream, Serializable} import scala.collection.mutable.Map import scala.collection.generic.Growable http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/1b5623fd/core/src/main/scala/org/apache/spark/broadcast/Broadcast.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/broadcast/Broadcast.scala b/core/src/main/scala/org/apache/spark/broadcast/Broadcast.scala index cf0904f..d113d40 100644 --- a/core/src/main/scala/org/apache/spark/broadcast/Broadcast.scala +++ b/core/src/main/scala/org/apache/spark/broadcast/Broadcast.scala @@ -17,6 +17,7 @@ package org.apache.spark.broadcast +import java.io.Serializable import java.util.concurrent.atomic.AtomicLong import org.apache.spark._
