Skip to content

Commit 24f4bf0

Browse files
foxishash211
authored andcommitted
inherit IO (apache#13)
1 parent acceb72 commit 24f4bf0

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/rest/kubernetes/KubernetesSparkRestServer.scala

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -164,10 +164,7 @@ private[spark] class KubernetesSparkRestServer(
164164
command += s"-Xmx$driverMemory"
165165
command += mainClass
166166
command ++= appArgs
167-
val pb = new ProcessBuilder(command: _*)
168-
Paths.get(sparkHome, "logs").toFile.mkdirs
169-
pb.redirectOutput(Paths.get(sparkHome, "logs", "stdout").toFile)
170-
pb.redirectError(Paths.get(sparkHome, "logs", "stderr").toFile)
167+
val pb = new ProcessBuilder(command: _*).inheritIO()
171168
val process = pb.start()
172169
ShutdownHookManager.addShutdownHook(() => {
173170
logInfo("Received stop command, shutting down the running Spark application...")

0 commit comments

Comments
 (0)