Repository: phoenix Updated Branches: refs/heads/4.11-HBase-1.2 edaf7991f -> 9f98e0660
PHOENIX-4041 CoprocessorHConnectionTableFactory should not open a new HConnection when shutting down Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/9f98e066 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/9f98e066 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/9f98e066 Branch: refs/heads/4.11-HBase-1.2 Commit: 9f98e0660e7d497e1511547cd8073bec70d0d3c1 Parents: edaf799 Author: Samarth Jain <[email protected]> Authored: Wed Jul 19 11:49:53 2017 -0700 Committer: Samarth Jain <[email protected]> Committed: Wed Jul 19 11:49:53 2017 -0700 ---------------------------------------------------------------------- .../phoenix/hbase/index/write/IndexWriterUtils.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/9f98e066/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/IndexWriterUtils.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/IndexWriterUtils.java b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/IndexWriterUtils.java index ea4ec1a..a82b277 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/IndexWriterUtils.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/write/IndexWriterUtils.java @@ -121,11 +121,13 @@ public class IndexWriterUtils { } @Override - public void shutdown() { + public synchronized void shutdown() { try { - getConnection(conf).close(); - } catch (IOException e) { - LOG.error("Exception caught while trying to close the HConnection used by CoprocessorHConnectionTableFactory"); + if (connection != null && !connection.isClosed()) { + connection.close(); + } + } catch (Throwable e) { + LOG.warn("Error while trying to close the HConnection used by CoprocessorHConnectionTableFactory", e); } }
