Repository: hbase
Updated Branches:
  refs/heads/master 2f4d0b94b -> 8143d5afa


HBASE-19848 Zookeeper thread leaks in hbase-spark bulkLoad method (Key Hutu)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8143d5af
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8143d5af
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8143d5af

Branch: refs/heads/master
Commit: 8143d5afa4a34c5f06a22e30b5017958b8c3f60c
Parents: 2f4d0b9
Author: tedyu <yuzhih...@gmail.com>
Authored: Fri Feb 2 05:45:13 2018 -0800
Committer: tedyu <yuzhih...@gmail.com>
Committed: Fri Feb 2 05:45:13 2018 -0800

----------------------------------------------------------------------
 .../main/scala/org/apache/hadoop/hbase/spark/HBaseContext.scala    | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/8143d5af/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseContext.scala
----------------------------------------------------------------------
diff --git 
a/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseContext.scala 
b/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseContext.scala
index eb0d683..d188057 100644
--- 
a/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseContext.scala
+++ 
b/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseContext.scala
@@ -706,6 +706,7 @@ class HBaseContext(@transient sc: SparkContext,
         compactionExclude)
       rollOverRequested = false
     })
+    if(null != conn) conn.close()
   }
 
   /**
@@ -868,6 +869,7 @@ class HBaseContext(@transient sc: SparkContext,
         compactionExclude)
       rollOverRequested = false
     })
+    if(null != conn) conn.close()
   }
 
   /**

Reply via email to