You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by an...@apache.org on 2020/10/20 05:23:25 UTC
[hbase] branch master updated: HBASE-25166 MobFileCompactionChore
is closing the master's shared cluster connection (#2514)
This is an automated email from the ASF dual-hosted git repository.
ankit pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/master by this push:
new 7d00e43 HBASE-25166 MobFileCompactionChore is closing the master's shared cluster connection (#2514)
7d00e43 is described below
commit 7d00e43dce576387f16e87fc7f89dd03358cc7a1
Author: Ankit Singhal <an...@apache.org>
AuthorDate: Mon Oct 19 22:22:33 2020 -0700
HBASE-25166 MobFileCompactionChore is closing the master's shared cluster connection (#2514)
---
.../java/org/apache/hadoop/hbase/mob/MobFileCompactionChore.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/MobFileCompactionChore.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/MobFileCompactionChore.java
index 3147298..dd5d289 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/MobFileCompactionChore.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/MobFileCompactionChore.java
@@ -31,7 +31,6 @@ import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
import org.apache.hadoop.hbase.client.CompactionState;
-import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.RegionInfo;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.client.TableState;
@@ -85,9 +84,7 @@ public class MobFileCompactionChore extends ScheduledChore {
boolean reported = false;
- try (Connection conn = master.getConnection();
- Admin admin = conn.getAdmin();) {
-
+ try (Admin admin = master.getConnection().getAdmin()) {
TableDescriptors htds = master.getTableDescriptors();
Map<String, TableDescriptor> map = htds.getAll();
for (TableDescriptor htd : map.values()) {