Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 7EFCD200D2E for ; Tue, 31 Oct 2017 11:25:06 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 7D92B160BF9; Tue, 31 Oct 2017 10:25:06 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id C2D511609EB for ; Tue, 31 Oct 2017 11:25:05 +0100 (CET) Received: (qmail 36743 invoked by uid 500); 31 Oct 2017 10:25:04 -0000 Mailing-List: contact issues-help@hbase.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list issues@hbase.apache.org Received: (qmail 36727 invoked by uid 99); 31 Oct 2017 10:25:04 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 31 Oct 2017 10:25:04 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 0C0811A0ACB for ; Tue, 31 Oct 2017 10:25:04 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -100.002 X-Spam-Level: X-Spam-Status: No, score=-100.002 tagged_above=-999 required=6.31 tests=[RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id hQCdzrLkVjFq for ; Tue, 31 Oct 2017 10:25:03 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id CED0E5FDFF for ; Tue, 31 Oct 2017 10:25:02 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 2E1A5E05C1 for ; Tue, 31 Oct 2017 10:25:02 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id B6FD6212FD for ; Tue, 31 Oct 2017 10:25:00 +0000 (UTC) Date: Tue, 31 Oct 2017 10:25:00 +0000 (UTC) From: "Wang, Xinglong (JIRA)" To: issues@hbase.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (HBASE-18602) rsgroup cleanup unassign code MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Tue, 31 Oct 2017 10:25:06 -0000 [ https://issues.apache.org/jira/browse/HBASE-18602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226567#comment-16226567 ] Wang, Xinglong commented on HBASE-18602: ---------------------------------------- [~chia7712] Thanks for merging the code. > rsgroup cleanup unassign code > ----------------------------- > > Key: HBASE-18602 > URL: https://issues.apache.org/jira/browse/HBASE-18602 > Project: HBase > Issue Type: Improvement > Components: rsgroup > Reporter: Wang, Xinglong > Assignee: Wang, Xinglong > Priority: Minor > Fix For: 2.0.0, 1.4.0, 1.5.0 > > Attachments: HBASE-18602-master-v1.patch, HBASE-18602-master-v2.patch, HBASE-18602-master-v3.patch, HBASE-18602-master-v3.patch, HBASE-18602-master-v3.patch, HBASE-18602-master-v4.patch > > > While walking through rsgroup code, I found that variable misplacedRegions has never been added any element into. This makes the unassign region code is not functional. And according to my test, it is actually unnecessary to do that. > RSGroupBasedLoadBalancer.java > {code:java} > private Map> correctAssignments( > Map> existingAssignments) > throws HBaseIOException{ > Map> correctAssignments = new TreeMap<>(); > List misplacedRegions = new LinkedList<>(); > correctAssignments.put(LoadBalancer.BOGUS_SERVER_NAME, new LinkedList<>()); > for (Map.Entry> assignments : existingAssignments.entrySet()){ > ServerName sName = assignments.getKey(); > correctAssignments.put(sName, new LinkedList<>()); > List regions = assignments.getValue(); > for (HRegionInfo region : regions) { > RSGroupInfo info = null; > try { > info = rsGroupInfoManager.getRSGroup( > rsGroupInfoManager.getRSGroupOfTable(region.getTable())); > } catch (IOException exp) { > LOG.debug("RSGroup information null for region of table " + region.getTable(), > exp); > } > if ((info == null) || (!info.containsServer(sName.getAddress()))) { > correctAssignments.get(LoadBalancer.BOGUS_SERVER_NAME).add(region); > } else { > correctAssignments.get(sName).add(region); > } > } > } > //TODO bulk unassign? > //unassign misplaced regions, so that they are assigned to correct groups. > for(HRegionInfo info: misplacedRegions) { > try { > this.masterServices.getAssignmentManager().unassign(info); > } catch (IOException e) { > throw new HBaseIOException(e); > } > } > return correctAssignments; > } > {code} -- This message was sent by Atlassian JIRA (v6.4.14#64029)