Skip to content

Commit 148167b

Browse files
rsotn-maprmgorbov
authored andcommitted
[MAPR-26414] Spark History Server Memory Leak fixed (apache#112)
1 parent 1a9b364 commit 148167b

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -310,8 +310,10 @@ private[spark] object EventLoggingListener extends Logging {
310310
}
311311

312312
codec.map(_.compressedInputStream(in)).getOrElse(in)
313-
} finally {
314-
in.close()
313+
} catch {
314+
case e: Exception =>
315+
in.close()
316+
throw e
315317
}
316318
}
317319

0 commit comments

Comments
 (0)