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 B0014200D34 for ; Fri, 20 Oct 2017 03:18:05 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id AE983160BEE; Fri, 20 Oct 2017 01:18:05 +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 01997160BEC for ; Fri, 20 Oct 2017 03:18:04 +0200 (CEST) Received: (qmail 30235 invoked by uid 500); 20 Oct 2017 01:18: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 30224 invoked by uid 99); 20 Oct 2017 01:18: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; Fri, 20 Oct 2017 01:18: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 3B5291A0D0B for ; Fri, 20 Oct 2017 01:18:03 +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-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id VeVbTKELlv3N for ; Fri, 20 Oct 2017 01:18:02 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 6921A5FCD4 for ; Fri, 20 Oct 2017 01:18:01 +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 B3828E0EF6 for ; Fri, 20 Oct 2017 01:18:00 +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 6E5CB21EE6 for ; Fri, 20 Oct 2017 01:18:00 +0000 (UTC) Date: Fri, 20 Oct 2017 01:18:00 +0000 (UTC) From: "Chia-Ping Tsai (JIRA)" To: issues@hbase.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Updated] (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: Fri, 20 Oct 2017 01:18:05 -0000 [ https://issues.apache.org/jira/browse/HBASE-18602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated HBASE-18602: ----------------------------------- Status: Open (was: Patch Available) > 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 > > 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 > > > 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)