diff options
| author | zsxwing <zsxwing@gmail.com> | 2014-11-14 22:25:41 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2014-11-14 22:25:41 -0800 |
| commit | dba14058230194122a715c219e35ab8eaa786321 (patch) | |
| tree | 30beec6a58de33160a8997cce9c91830b0d4a20f /core | |
| parent | 7fe08b43c78bf9e8515f671e72aa03a83ea782f8 (diff) | |
| download | spark-dba14058230194122a715c219e35ab8eaa786321.tar.gz spark-dba14058230194122a715c219e35ab8eaa786321.tar.bz2 spark-dba14058230194122a715c219e35ab8eaa786321.zip | |
[SPARK-4379][Core] Change Exception to SparkException in checkpoint
It's better to change to SparkException. However, it's a breaking change since it will change the exception type.
Author: zsxwing <zsxwing@gmail.com>
Closes #3241 from zsxwing/SPARK-4379 and squashes the following commits:
409f3af [zsxwing] Change Exception to SparkException in checkpoint
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/rdd/RDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 716f2dd177..cb64d43c6c 100644 --- a/core/src/main/scala/org/apache/spark/rdd/RDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/RDD.scala @@ -1202,7 +1202,7 @@ abstract class RDD[T: ClassTag]( */ def checkpoint() { if (context.checkpointDir.isEmpty) { - throw new Exception("Checkpoint directory has not been set in the SparkContext") + throw new SparkException("Checkpoint directory has not been set in the SparkContext") } else if (checkpointData.isEmpty) { checkpointData = Some(new RDDCheckpointData(this)) checkpointData.get.markForCheckpoint() |