From c81bda958b2ded7623d7bdce944c0092e7d4b55e Mon Sep 17 00:00:00 2001
From: Imran M Yousuf <imyousuf@smartitengineering.com>
Date: Wed, 8 Sep 2010 04:52:37 +0600
Subject: [PATCH] Close the streams when writing serializable id to object
 stream

Signed-off-by: Imran M Yousuf <imyousuf@smartitengineering.com>
---
 smart-hbase-dao/pom.xml                                             | 4 ++++
 .../main/java/com/smartitengineering/dao/impl/hbase/CommonDao.java  | 6 +++++-
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/smart-hbase-dao/pom.xml b/smart-hbase-dao/pom.xml
index 41dc620..bc12b30 100644
--- a/smart-hbase-dao/pom.xml
+++ b/smart-hbase-dao/pom.xml
@@ -56,6 +56,10 @@
       <artifactId>smart-abstract-dao</artifactId>
     </dependency>
     <dependency>
+      <groupId>commons-io</groupId>
+      <artifactId>commons-io</artifactId>
+    </dependency>
+    <dependency>
       <groupId>org.apache.hbase</groupId>
       <artifactId>hbase</artifactId>
       <classifier>tests</classifier>
diff --git a/smart-hbase-dao/src/main/java/com/smartitengineering/dao/impl/hbase/CommonDao.java b/smart-hbase-dao/src/main/java/com/smartitengineering/dao/impl/hbase/CommonDao.java
index 8dd5820..fd3c4d2 100644
--- a/smart-hbase-dao/src/main/java/com/smartitengineering/dao/impl/hbase/CommonDao.java
+++ b/smart-hbase-dao/src/main/java/com/smartitengineering/dao/impl/hbase/CommonDao.java
@@ -52,6 +52,7 @@ import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.concurrent.Future;
+import org.apache.commons.io.IOUtils;
 import org.apache.hadoop.hbase.client.Delete;
 import org.apache.hadoop.hbase.client.Get;
 import org.apache.hadoop.hbase.client.HTableInterface;
@@ -208,7 +209,10 @@ public class CommonDao<Template extends PersistentDTO, IdType extends Serializab
         }
         else if (id != null) {
           final ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
-          new ObjectOutputStream(byteArrayOutputStream).writeObject(id);
+          final ObjectOutputStream objectOutputStream = new ObjectOutputStream(byteArrayOutputStream);
+          objectOutputStream.writeObject(id);
+          IOUtils.closeQuietly(objectOutputStream);
+          IOUtils.closeQuietly(byteArrayOutputStream);
           rowId = byteArrayOutputStream.toByteArray();
         }
         else {
-- 
2.11.4.GIT