Skip to content

Commit

Permalink
Fix SPARK-1629: Spark should inline use of commons-lang `SystemUtils.…
Browse files Browse the repository at this point in the history
…IS_OS_WINDOWS`
  • Loading branch information
witgo committed Apr 27, 2014
1 parent 8e37ed6 commit 49e248e
Showing 1 changed file with 10 additions and 4 deletions.
14 changes: 10 additions & 4 deletions core/src/main/scala/org/apache/spark/util/Utils.scala
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@ import scala.io.Source
import scala.reflect.ClassTag

import com.google.common.io.Files
import org.apache.commons.lang.SystemUtils
import com.google.common.util.concurrent.ThreadFactoryBuilder
import org.apache.hadoop.fs.{FileSystem, FileUtil, Path}
import org.json4s._
Expand All @@ -49,7 +48,7 @@ private[spark] object Utils extends Logging {
val random = new Random()

def sparkBin(sparkHome: String, which: String): File = {
val suffix = if (SystemUtils.IS_OS_WINDOWS) ".cmd" else ""
val suffix = if (isWindows) ".cmd" else ""
new File(sparkHome + File.separator + "bin", which + suffix)
}

Expand Down Expand Up @@ -609,7 +608,7 @@ private[spark] object Utils extends Logging {
*/
def isSymlink(file: File): Boolean = {
if (file == null) throw new NullPointerException("File must not be null")
if (SystemUtils.IS_OS_WINDOWS) return false
if (isWindows) return false
val fileInCanonicalDir = if (file.getParent() == null) {
file
} else {
Expand Down Expand Up @@ -1013,7 +1012,7 @@ private[spark] object Utils extends Logging {
throw new IOException("Destination must be relative")
}
var cmdSuffix = ""
val linkCmd = if (SystemUtils.IS_OS_WINDOWS) {
val linkCmd = if (isWindows) {
// refer to http://technet.microsoft.com/en-us/library/cc771254.aspx
cmdSuffix = " /s /e /k /h /y /i"
"cmd /c xcopy "
Expand Down Expand Up @@ -1056,4 +1055,11 @@ private[spark] object Utils extends Logging {
def getHadoopFileSystem(path: String): FileSystem = {
getHadoopFileSystem(new URI(path))
}

/**
* return true if this is Windows.
*/
def isWindows = Option(System.getProperty("os.name")).
map(_.startsWith("Windows")).getOrElse(false)

}

0 comments on commit 49e248e

Please sign in to comment.