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 10E5C200C03 for ; Fri, 6 Jan 2017 09:10:02 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 0F938160B37; Fri, 6 Jan 2017 08:10:02 +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 8739B160B1F for ; Fri, 6 Jan 2017 09:10:01 +0100 (CET) Received: (qmail 99019 invoked by uid 500); 6 Jan 2017 08:09:59 -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 98908 invoked by uid 99); 6 Jan 2017 08:09:59 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 06 Jan 2017 08:09:59 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 889882C1F5A for ; Fri, 6 Jan 2017 08:09:59 +0000 (UTC) Date: Fri, 6 Jan 2017 08:09:59 +0000 (UTC) From: "Phil Yang (JIRA)" To: issues@hbase.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (HBASE-17432) Use less threads to read WAL in replication MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 06 Jan 2017 08:10:02 -0000 Phil Yang created HBASE-17432: --------------------------------- Summary: Use less threads to read WAL in replication Key: HBASE-17432 URL: https://issues.apache.org/jira/browse/HBASE-17432 Project: HBase Issue Type: Improvement Components: Replication Reporter: Phil Yang Assignee: Phil Yang Fix For: 2.0.0 Now for each peer and each failover source we use different threads to read WAL, which means one WAL file will be read many times if we have many peers. We can read logs in one thread and push them to peers concurrently. Some cases should be considered. For example, if one of peers is stuck, the reading thread should kick it out of concurrent peers and use an independent thread to read logs for this peer just like old style. If finally this peer's progress catch up other peers, they can be merged back. Of course, failover threads should still be independent because they read different WAL files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)