Remove unnecessary close

integration-test/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/ProcessUtils.scala

@@ -32,14 +32,11 @@ object ProcessUtils extends Logging {
     val proc = pb.start()
     val outputLines = new ArrayBuffer[String]
 
-    Utils.tryWithResource(Source.fromInputStream(proc.getInputStream, "UTF-8")) { output =>
-      for (line <- output.getLines) {
+    Utils.tryWithResource(proc.getInputStream)(
+      Source.fromInputStream(_, "UTF-8").getLines().foreach { line =>
         logInfo(line)
         outputLines += line
-      }
-    }{
-      output => output.close()
-    }
+      })
     assert(proc.waitFor(timeout, TimeUnit.SECONDS),
       s"Timed out while executing ${fullCommand.mkString(" ")}")
     assert(proc.exitValue == 0, s"Failed to execute ${fullCommand.mkString(" ")}")

integration-test/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/Utils.scala

@@ -26,11 +26,6 @@ object Utils extends Logging {
     try f.apply(resource) finally resource.close()
   }
 
-  def tryWithResource[R, T](createResource: => R)(f: R => T)(closeResource: R => T): T = {
-    val resource = createResource
-    try f.apply(resource) finally closeResource(resource)
-  }
-
   def checkAndGetK8sMasterUrl(rawMasterURL: String): String = {
     require(rawMasterURL.startsWith("k8s://"),
       "Kubernetes master URL must start with k8s://.")