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

2018-02-02 05:45:13 -08:00 · 2018-02-02 05:45:13 -08:00 · 8143d5afa4
parent 2f4d0b94bc
commit 8143d5afa4
1 changed files with 2 additions and 0 deletions
--- 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()
  }

  /**