Return-Path: X-Original-To: apmail-hbase-issues-archive@www.apache.org Delivered-To: apmail-hbase-issues-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 4C78918882 for ; Wed, 16 Sep 2015 15:04:46 +0000 (UTC) Received: (qmail 71564 invoked by uid 500); 16 Sep 2015 15:04:46 -0000 Delivered-To: apmail-hbase-issues-archive@hbase.apache.org Received: (qmail 71511 invoked by uid 500); 16 Sep 2015 15:04:46 -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 71500 invoked by uid 99); 16 Sep 2015 15:04:46 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 16 Sep 2015 15:04:46 +0000 Date: Wed, 16 Sep 2015 15:04:46 +0000 (UTC) From: "Ted Yu (JIRA)" To: issues@hbase.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (HBASE-14431) AsyncRpcClient#removeConnection() never removes connection from connections pool if server fails MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/HBASE-14431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14790514#comment-14790514 ] Ted Yu commented on HBASE-14431: -------------------------------- lgtm nit: connection.hashCode() is computed twice. You can save the return value in a local variable. > AsyncRpcClient#removeConnection() never removes connection from connections pool if server fails > ------------------------------------------------------------------------------------------------ > > Key: HBASE-14431 > URL: https://issues.apache.org/jira/browse/HBASE-14431 > Project: HBase > Issue Type: Bug > Components: IPC/RPC > Affects Versions: 2.0.0, 1.0.2, 1.1.2 > Reporter: Samir Ahmic > Assignee: Samir Ahmic > Priority: Critical > Attachments: HBASE-14431.patch > > > I was playing with master branch in distributed mode (3 rs + master + backup_master) and notice strange behavior when i was testing this sequence of events on single rs: /kill/start/run_balancer while client was writing data to cluster (LoadTestTool). > I have notice that LTT fails with following: > {code} > 2015-09-09 11:05:58,364 INFO [main] client.AsyncProcess: #2, waiting for some tasks to finish. Expected max=0, tasksInProgress=35 > Exception in thread "main" org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException: Failed 1 action: BindException: 1 time, > at org.apache.hadoop.hbase.client.AsyncProcess$BatchErrors.makeException(AsyncProcess.java:228) > at org.apache.hadoop.hbase.client.AsyncProcess$BatchErrors.access$1800(AsyncProcess.java:208) > at org.apache.hadoop.hbase.client.AsyncProcess.waitForAllPreviousOpsAndReset(AsyncProcess.java:1697) > at org.apache.hadoop.hbase.client.BufferedMutatorImpl.backgroundFlushCommits(BufferedMutatorImpl.java:211) > {code} > After some digging and adding some more logging in code i have notice that following condition in {code}AsyncRpcClient.removeConnection(AsyncRpcChannel connection) {code} is never true: > {code} > if (connectionInPool == connection) { > {code} > causing that {code}AsyncRpcChannel{code} connection is never removed from {code}connections{code} pool in case rs fails. > After changing this condition to: > {code} > if (connectionInPool.address.equals(connection.address)) { > {code} > issue was resolved and client was removing failed server from connections pool. > I will attach patch after running some more tests. -- This message was sent by Atlassian JIRA (v6.3.4#6332)