diff options
| author | CrazyJvm <crazyjvm@gmail.com> | 2014-10-22 00:51:33 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2014-10-22 00:51:33 -0700 |
| commit | f05e09b4c95d799bdda3c3ff7fb76a4cd656415d (patch) | |
| tree | 45e5efd5692ac2d81926b09927b1cfbe81b924d3 | |
| parent | bae4ca3bbf75cf5b57a098a95848b0fd65bc241e (diff) | |
| download | spark-f05e09b4c95d799bdda3c3ff7fb76a4cd656415d.tar.gz spark-f05e09b4c95d799bdda3c3ff7fb76a4cd656415d.tar.bz2 spark-f05e09b4c95d799bdda3c3ff7fb76a4cd656415d.zip | |
use isRunningLocally rather than runningLocally
runningLocally is deprecated now
Author: CrazyJvm <crazyjvm@gmail.com>
Closes #2879 from CrazyJvm/runningLocally and squashes the following commits:
bec0b3e [CrazyJvm] use isRunningLocally rather than runningLocally
| -rw-r--r-- | core/src/main/scala/org/apache/spark/CacheManager.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/CacheManager.scala b/core/src/main/scala/org/apache/spark/CacheManager.scala index d89bb50076..80da62c44e 100644 --- a/core/src/main/scala/org/apache/spark/CacheManager.scala +++ b/core/src/main/scala/org/apache/spark/CacheManager.scala @@ -61,7 +61,7 @@ private[spark] class CacheManager(blockManager: BlockManager) extends Logging { val computedValues = rdd.computeOrReadCheckpoint(partition, context) // If the task is running locally, do not persist the result - if (context.runningLocally) { + if (context.isRunningLocally) { return computedValues } |