You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2018/02/05 04:14:36 UTC
[02/28] hbase git commit: HBASE-19848 Zookeeper thread leaks in
hbase-spark bulkLoad method (Key Hutu)
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 <yu...@gmail.com>
Authored: Fri Feb 2 05:45:13 2018 -0800
Committer: tedyu <yu...@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()
}
/**