From 8143d5afa4a34c5f06a22e30b5017958b8c3f60c Mon Sep 17 00:00:00 2001 From: tedyu Date: Fri, 2 Feb 2018 05:45:13 -0800 Subject: [PATCH] HBASE-19848 Zookeeper thread leaks in hbase-spark bulkLoad method (Key Hutu) --- .../main/scala/org/apache/hadoop/hbase/spark/HBaseContext.scala | 2 ++ 1 file changed, 2 insertions(+) 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 eb0d6835d69..d1880576374 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() } /**