You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by vj...@apache.org on 2020/09/13 12:11:22 UTC

[hbase] branch master updated: HBASE-25016 Should close ResultScanner in MetaTableAccessor.scanByRegionEncodedName

This is an automated email from the ASF dual-hosted git repository.

vjasani 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 a393fc5  HBASE-25016 Should close ResultScanner in MetaTableAccessor.scanByRegionEncodedName
a393fc5 is described below

commit a393fc594c00489a44b07ba9cf3ebf315f9fc2a3
Author: niuyulin <ny...@163.com>
AuthorDate: Sun Sep 13 17:32:42 2020 +0530

    HBASE-25016 Should close ResultScanner in MetaTableAccessor.scanByRegionEncodedName
    
    Closes #2390
    
    Signed-off-by: Viraj Jasani <vj...@apache.org>
---
 .../src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/hbase-balancer/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java b/hbase-balancer/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
index f5beda4..4b226d9 100644
--- a/hbase-balancer/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
+++ b/hbase-balancer/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
@@ -244,13 +244,14 @@ public final class MetaTableAccessor {
    * @throws IOException if any errors occur while querying META.
    */
   public static Result scanByRegionEncodedName(Connection connection, String regionEncodedName)
-    throws IOException {
+      throws IOException {
     RowFilter rowFilter =
-      new RowFilter(CompareOperator.EQUAL, new SubstringComparator(regionEncodedName));
+        new RowFilter(CompareOperator.EQUAL, new SubstringComparator(regionEncodedName));
     Scan scan = getMetaScan(connection, 1);
     scan.setFilter(rowFilter);
-    ResultScanner resultScanner = getMetaHTable(connection).getScanner(scan);
-    return resultScanner.next();
+    try (ResultScanner resultScanner = getMetaHTable(connection).getScanner(scan)) {
+      return resultScanner.next();
+    }
   }
 
   /**