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/HBASE-19064 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() } /**