You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2013/12/04 19:30:08 UTC
[2/3] git commit: Marked doCheckpointCalled as transient.
Marked doCheckpointCalled as transient.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/974a69d7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/974a69d7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/974a69d7
Branch: refs/heads/master
Commit: 974a69d79c4bf64fd9f27b65c1c464d33e647e20
Parents: e34b469
Author: Reynold Xin <rx...@apache.org>
Authored: Tue Dec 3 11:34:38 2013 -0800
Committer: Reynold Xin <rx...@apache.org>
Committed: Tue Dec 3 11:34:38 2013 -0800
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/rdd/RDD.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/974a69d7/core/src/main/scala/org/apache/spark/rdd/RDD.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/rdd/RDD.scala b/core/src/main/scala/org/apache/spark/rdd/RDD.scala
index 96e4841..893708f 100644
--- a/core/src/main/scala/org/apache/spark/rdd/RDD.scala
+++ b/core/src/main/scala/org/apache/spark/rdd/RDD.scala
@@ -940,7 +940,7 @@ abstract class RDD[T: ClassManifest](
private var storageLevel: StorageLevel = StorageLevel.NONE
/** Record user function generating this RDD. */
- private[spark] val origin = Utils.formatSparkCallSite
+ @transient private[spark] val origin = Utils.formatSparkCallSite
private[spark] def elementClassManifest: ClassManifest[T] = classManifest[T]
@@ -955,7 +955,7 @@ abstract class RDD[T: ClassManifest](
def context = sc
// Avoid handling doCheckpoint multiple times to prevent excessive recursion
- private var doCheckpointCalled = false
+ @transient private var doCheckpointCalled = false
/**
* Performs the checkpointing of this RDD by saving this. It is called by the DAGScheduler