From 3d8c2c693197c77e3a83a5b07dc4c874413ee033 Mon Sep 17 00:00:00 2001 From: Jon Bringhurst Date: Mon, 28 Apr 2014 10:15:47 -0700 Subject: [PATCH 1/1] Close FIS after Properties.load. --- core/src/main/scala/kafka/utils/Utils.scala | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/utils/Utils.scala b/core/src/main/scala/kafka/utils/Utils.scala index 6bfbac1..7331e9f 100644 --- a/core/src/main/scala/kafka/utils/Utils.scala +++ b/core/src/main/scala/kafka/utils/Utils.scala @@ -140,9 +140,17 @@ object Utils extends Logging { * @param filename The path of the file to read */ def loadProps(filename: String): Properties = { - val propStream = new FileInputStream(filename) val props = new Properties() - props.load(propStream) + var propStream:InputStream = null + try { + propStream = new FileInputStream(filename) + props.load(propStream) + } + finally { + if(propStream != null) { + propStream.close + } + } props } -- 1.7.12.4