diff options
| author | Reynold Xin <rxin@apache.org> | 2014-01-14 11:30:59 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-01-14 11:30:59 -0800 |
| commit | 1b5623fd0bd716d3c556371caabbf94abcc6fb8d (patch) | |
| tree | 6315dd64a541ea1c901ebb847be9adfaf735f324 | |
| parent | 55db77416b4fd8c51e0b0c3cc704c700f73bdc2e (diff) | |
| download | spark-1b5623fd0bd716d3c556371caabbf94abcc6fb8d.tar.gz spark-1b5623fd0bd716d3c556371caabbf94abcc6fb8d.tar.bz2 spark-1b5623fd0bd716d3c556371caabbf94abcc6fb8d.zip | |
Maintain Serializable API compatibility by reverting back to java.io.Serializable for Broadcast and Accumulator.
| -rw-r--r-- | core/src/main/scala/org/apache/spark/Accumulators.scala | 2 | ||||
| -rw-r--r-- | core/src/main/scala/org/apache/spark/broadcast/Broadcast.scala | 1 |
2 files changed, 2 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/Accumulators.scala b/core/src/main/scala/org/apache/spark/Accumulators.scala index fe1537a610..df01b2e942 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 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 cf0904fc85..d113d40405 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._ |