diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/rest/kubernetes/KubernetesSparkRestServer.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/rest/kubernetes/KubernetesSparkRestServer.scala
index 2ca3d4a8c0656..837706ca9f5a8 100644
--- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/rest/kubernetes/KubernetesSparkRestServer.scala
+++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/rest/kubernetes/KubernetesSparkRestServer.scala
@@ -164,10 +164,7 @@ private[spark] class KubernetesSparkRestServer(
             command += s"-Xmx$driverMemory"
             command += mainClass
             command ++= appArgs
-            val pb = new ProcessBuilder(command: _*)
-            Paths.get(sparkHome, "logs").toFile.mkdirs
-            pb.redirectOutput(Paths.get(sparkHome, "logs", "stdout").toFile)
-            pb.redirectError(Paths.get(sparkHome, "logs", "stderr").toFile)
+            val pb = new ProcessBuilder(command: _*).inheritIO()
             val process = pb.start()
             ShutdownHookManager.addShutdownHook(() => {
               logInfo("Received stop command, shutting down the running Spark application...")