emove the unnecessary trywithresources

Reza Safi · Reza Safi · commit 4c1f0732e49f · 2018-11-30T18:30:05.000-05:00
diff --git a/core/src/main/scala/org/apache/spark/executor/ProcfsMetricsGetter.scala b/core/src/main/scala/org/apache/spark/executor/ProcfsMetricsGetter.scala
@@ -173,7 +173,7 @@ private[spark] class ProcfsMetricsGetter(val procfsDir: String = "/proc/") exten
       Utils.tryWithResource(new InputStreamReader(
         new FileInputStream(
           new File(pidDir, procfsStatFile)), Charset.forName("UTF-8"))) { fReader =>
-        Utils.tryWithResource( new BufferedReader(fReader)) { in =>
+          val in = new BufferedReader(fReader)
           val procInfo = in.readLine
           val procInfoSplit = procInfo.split(" ")
           val vmem = procInfoSplit(22).toLong
@@ -196,7 +196,6 @@ private[spark] class ProcfsMetricsGetter(val procfsDir: String = "/proc/") exten
               otherRSSTotal = allMetrics.otherRSSTotal + (rssMem)
             )
           }
-        }
       }
     } catch {
       case f: IOException =>

Original file line number	Diff line number	Diff line change
`@@ -173,7 +173,7 @@ private[spark] class ProcfsMetricsGetter(val procfsDir: String = "/proc/") exten`
`173`	`173`	`Utils.tryWithResource(new InputStreamReader(`
`174`	`174`	`new FileInputStream(`
`175`	`175`	`new File(pidDir, procfsStatFile)), Charset.forName("UTF-8"))) { fReader =>`
`176`		`- Utils.tryWithResource( new BufferedReader(fReader)) { in =>`
	`176`	`+ val in = new BufferedReader(fReader)`
`177`	`177`	`val procInfo = in.readLine`
`178`	`178`	`val procInfoSplit = procInfo.split(" ")`
`179`	`179`	`val vmem = procInfoSplit(22).toLong`
`@@ -196,7 +196,6 @@ private[spark] class ProcfsMetricsGetter(val procfsDir: String = "/proc/") exten`
`196`	`196`	`otherRSSTotal = allMetrics.otherRSSTotal + (rssMem)`
`197`	`197`	`)`
`198`	`198`	`}`
`199`		`- }`
`200`	`199`	`}`
`201`	`200`	`} catch {`
`202`	`201`	`case f: IOException =>`