diff options
| author | Mridul Muralidharan <mridul@gmail.com> | 2014-01-17 18:28:55 +0530 |
|---|---|---|
| committer | Mridul Muralidharan <mridul@gmail.com> | 2014-01-17 18:28:55 +0530 |
| commit | b690e11d9c945c7293015db8c96f7ba0da33ec0c (patch) | |
| tree | c4af382cf64797f73489a5225a69a136a4ddd015 /core | |
| parent | edd82c58a22924c91f11ebadf00bdca3cff16c79 (diff) | |
| download | spark-b690e11d9c945c7293015db8c96f7ba0da33ec0c.tar.gz spark-b690e11d9c945c7293015db8c96f7ba0da33ec0c.tar.bz2 spark-b690e11d9c945c7293015db8c96f7ba0da33ec0c.zip | |
Address review comment
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/api/java/JavaSparkContext.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/api/java/JavaSparkContext.scala b/core/src/main/scala/org/apache/spark/api/java/JavaSparkContext.scala index c8778704f5..33c931b1a7 100644 --- a/core/src/main/scala/org/apache/spark/api/java/JavaSparkContext.scala +++ b/core/src/main/scala/org/apache/spark/api/java/JavaSparkContext.scala @@ -401,7 +401,7 @@ class JavaSparkContext(val sc: SparkContext) extends JavaSparkContextVarargsWork sc.setCheckpointDir(dir) } - def getCheckpointDir = sc.getCheckpointDir.getOrElse(null) + def getCheckpointDir = JavaUtils.optionToOptional(sc.getCheckpointDir) protected def checkpointFile[T](path: String): JavaRDD[T] = { implicit val cm: ClassTag[T] = |