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 9C878200B57 for ; Fri, 22 Jul 2016 19:47:22 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 9B2D3160A5A; Fri, 22 Jul 2016 17:47:22 +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 E3A45160A6D for ; Fri, 22 Jul 2016 19:47:21 +0200 (CEST) Received: (qmail 18408 invoked by uid 500); 22 Jul 2016 17:47:21 -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 18361 invoked by uid 99); 22 Jul 2016 17:47:21 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 22 Jul 2016 17:47:21 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id BEF6C2C0D61 for ; Fri, 22 Jul 2016 17:47:20 +0000 (UTC) Date: Fri, 22 Jul 2016 17:47:20 +0000 (UTC) From: "Vivek Koppuru (JIRA)" To: issues@hbase.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Updated] (HBASE-15866) Split hbase.rpc.timeout into *.read.timeout and *.write.timeout MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 22 Jul 2016 17:47:22 -0000 [ https://issues.apache.org/jira/browse/HBASE-15866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vivek Koppuru updated HBASE-15866: ---------------------------------- Labels: newbie patch (was: ) Affects Version/s: 2.0.0 Status: Patch Available (was: In Progress) I split the rpcTimeout in HTable.java into readRpcTimeout and writeRpcTimeout, which can also go back to the rpcTimeout value that would be set if the user did not configure those values. Then throughout HTable, whenever making an rpcCallerFactory call, I would pass the appropriate read/write rpc timeout. I also made a change to the AsyncProcess class constructor to allow for the use of writeRpcTimeout, which then I made appropriate changes to BufferedMutatorImpl.java, ConnectionImplementation.java, HTableMultiplexer.java, and TestAsyncProcess.java to account for this parameter change and passed in the appropriate rpc timeout. Finally, I made sure I included constants in HConstants.java to retrieve the value of "hbase.rpc.read.timeout" and "hbase.rpc.write.timeout" and to also allow for fallback to "hbase.rpc.timeout" and the default rpc timeout if none of those are set. > Split hbase.rpc.timeout into *.read.timeout and *.write.timeout > --------------------------------------------------------------- > > Key: HBASE-15866 > URL: https://issues.apache.org/jira/browse/HBASE-15866 > Project: HBase > Issue Type: Bug > Affects Versions: 2.0.0 > Reporter: Andrew Purtell > Assignee: Vivek Koppuru > Labels: newbie, patch > Fix For: 2.0.0 > > Attachments: read-write-rpc-timeouts.patch > > > We have a single tunable for the RPC timeout interval - hbase.rpc.timeout. This is fine for the general case but there are use cases where it would be advantageous to set two separate timeouts for reads (gets, scans, perhaps with significant server side filtering - although the new scanner heartbeat feature mitigates where available) and mutations (fail fast under tight SLA, resubmit or take mitigating action). > I propose we refer to a configuration setting "hbase.rpc.read.timeout" when handling read operations and "hbase.rpc.write.timeout" when handling write operations. If those values are not set in the configuration, fall back to the value of "hbase.rpc.timeout" or its default. > So for example in HTable instead of one global timeout for each RPC (rpcTimeout), there would be a readRpcTimeout and writeRpcTimeout also set up in HTable#finishSetup. Then wherever we set up RPC with RpcRetryingCallerFactory#newCaller(int rpcTimeout) we pass in the read or write timeout depending on what the op is. > In general I don't like the idea of adding configuration parameters to our already heavyweight set, but I think the inability to control timeouts separately for reads and writes is an operational deficit. > See also PHOENIX-2916. -- This message was sent by Atlassian JIRA (v6.3.4#6332)