File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
core/src/main/scala/org/apache/spark/executor Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -174,14 +174,14 @@ private[spark] class ProcfsMetricsGetter(
174174 // http://man7.org/linux/man-pages/man5/proc.5.html
175175 try {
176176 val pidDir = new File (procfsDir, pid.toString)
177- Utils .tryWithResource( new InputStreamReader (
177+ Utils .tryWithResource(new InputStreamReader (
178178 new FileInputStream (
179179 new File (pidDir, procfsStatFile)), Charset .forName(" UTF-8" ))) { fReader =>
180180 Utils .tryWithResource( new BufferedReader (fReader)) { in =>
181181 val procInfo = in.readLine
182182 val procInfoSplit = procInfo.split(" " )
183183 val vmem = procInfoSplit(22 ).toLong
184- val rssMem = procInfoSplit(23 ).toLong* pageSize
184+ val rssMem = procInfoSplit(23 ).toLong * pageSize
185185 if (procInfoSplit(1 ).toLowerCase(Locale .US ).contains(" java" )) {
186186 allMetrics.copy(
187187 jvmVmemTotal = allMetrics.jvmVmemTotal + vmem,
You can’t perform that action at this time.
0 commit comments