From 3e7d35e5196477418a6e2e8e2c3308bfd88b78a6 Mon Sep 17 00:00:00 2001
From: wangxiaoyu8 <wangxiaoyu1@jd.com>
Date: Wed, 9 Sep 2015 17:22:18 +0800
Subject: [PATCH 01/16] KYLIN-948 Hive connection resouce not close

---
 .../org/apache/kylin/monitor/HiveJdbcClient.java   | 24 ++++++++++++++++++++--
 1 file changed, 22 insertions(+), 2 deletions(-)

diff --git a/monitor/src/main/java/org/apache/kylin/monitor/HiveJdbcClient.java b/monitor/src/main/java/org/apache/kylin/monitor/HiveJdbcClient.java
index ef4cceb..5856fb5 100644
--- a/monitor/src/main/java/org/apache/kylin/monitor/HiveJdbcClient.java
+++ b/monitor/src/main/java/org/apache/kylin/monitor/HiveJdbcClient.java
@@ -166,7 +166,27 @@ public class HiveJdbcClient {
             FileUtils.appendResultToHdfs(each_day_percentile_file, new String[] { res.getString(1), res.getString(2), res.getString(3) });
             logger.info(res.getString(1) + "," + res.getString(2) + "," + res.getString(3));
         }
-
+        if (res != null) {
+            try {
+                res.close();
+            } catch (SQLException e) {
+                logger.error("failed to close", e);
+            }
+        }
+        if (stmt != null){
+            try {
+                stmt.close();
+            } catch (SQLException e) {
+                logger.error("failed to close", e);
+            }
+        }
+        if (con != null) {
+            try {
+                con.close();
+            } catch (SQLException e) {
+                logger.error("failed to close", e);
+            }
+        }
     }
 
     public String generateQueryLogSql() {
@@ -216,4 +236,4 @@ public class HiveJdbcClient {
         return sql.replace("[START_DATE]", "'" + startDate + "'").replace("[END_DATE]", "'" + endDate + "'");
     }
 
-}
\ No newline at end of file
+}
-- 
1.9.1