diff options
| author | xukun 00228947 <xukun.xu@huawei.com> | 2015-02-17 18:59:41 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-02-17 18:59:41 +0000 |
| commit | b271c265b742fa6947522eda4592e9e6a7fd1f3a (patch) | |
| tree | aadfb4f0ea48f4a21f534515655dc618cb4cdf50 | |
| parent | d8f69cf78862d13a48392a0b94388b8d403523da (diff) | |
| download | spark-b271c265b742fa6947522eda4592e9e6a7fd1f3a.tar.gz spark-b271c265b742fa6947522eda4592e9e6a7fd1f3a.tar.bz2 spark-b271c265b742fa6947522eda4592e9e6a7fd1f3a.zip | |
[SPARK-5661]function hasShutdownDeleteTachyonDir should use shutdownDeleteTachyonPaths to determine whether contains file
hasShutdownDeleteTachyonDir(file: TachyonFile) should use shutdownDeleteTachyonPaths(not shutdownDeletePaths) to determine Whether contain file. To solve it ,delete two unused function.
Author: xukun 00228947 <xukun.xu@huawei.com>
Author: viper-kun <xukun.xu@huawei.com>
Closes #4418 from viper-kun/deleteunusedfun and squashes the following commits:
87340eb [viper-kun] fix style
3d6c69e [xukun 00228947] fix bug
2bc397e [xukun 00228947] deleteunusedfun
| -rw-r--r-- | core/src/main/scala/org/apache/spark/util/Utils.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/util/Utils.scala b/core/src/main/scala/org/apache/spark/util/Utils.scala index c06bd6fab0..df21ed37e7 100644 --- a/core/src/main/scala/org/apache/spark/util/Utils.scala +++ b/core/src/main/scala/org/apache/spark/util/Utils.scala @@ -213,8 +213,8 @@ private[spark] object Utils extends Logging { // Is the path already registered to be deleted via a shutdown hook ? def hasShutdownDeleteTachyonDir(file: TachyonFile): Boolean = { val absolutePath = file.getPath() - shutdownDeletePaths.synchronized { - shutdownDeletePaths.contains(absolutePath) + shutdownDeleteTachyonPaths.synchronized { + shutdownDeleteTachyonPaths.contains(absolutePath) } } |