Return-Path: Delivered-To: apmail-lucene-hadoop-dev-archive@locus.apache.org Received: (qmail 76415 invoked from network); 4 Oct 2007 03:19:43 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 4 Oct 2007 03:19:43 -0000 Received: (qmail 86067 invoked by uid 500); 4 Oct 2007 03:19:31 -0000 Delivered-To: apmail-lucene-hadoop-dev-archive@lucene.apache.org Received: (qmail 86034 invoked by uid 500); 4 Oct 2007 03:19:31 -0000 Mailing-List: contact hadoop-dev-help@lucene.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: hadoop-dev@lucene.apache.org Delivered-To: mailing list hadoop-dev@lucene.apache.org Received: (qmail 86025 invoked by uid 99); 4 Oct 2007 03:19:31 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 03 Oct 2007 20:19:31 -0700 X-ASF-Spam-Status: No, hits=-100.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO brutus.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 04 Oct 2007 03:19:41 +0000 Received: from brutus (localhost [127.0.0.1]) by brutus.apache.org (Postfix) with ESMTP id 9004971422C for ; Wed, 3 Oct 2007 20:18:51 -0700 (PDT) Message-ID: <4673623.1191467931586.JavaMail.jira@brutus> Date: Wed, 3 Oct 2007 20:18:51 -0700 (PDT) From: "Raghu Angadi (JIRA)" To: hadoop-dev@lucene.apache.org Subject: [jira] Commented: (HADOOP-1942) Increase the concurrency of transaction logging to edits log In-Reply-To: <32101259.1190700290842.JavaMail.jira@brutus> MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/HADOOP-1942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#action_12532313 ] Raghu Angadi commented on HADOOP-1942: -------------------------------------- FSEditLog.java : - in logSync() : mytxid should be set to min(id.txid, txid) otherwise, when id.txtd is MAX_VALUE, thread could stay in logSync() for longer time (i.e. it will always sync). This can happen when completeFile() returns false, which is quite often. -- Another option is not to reset id.txid but provide logSyncTillNow(), which calls logSync() with id.txid set to current txid, if such a call is required. - synchronized (editstream) is not required inside logEdit(). Looks like it existed before but can be removed. - there are two calls to System.currentTimeMillis() in side editLog(). editLog() is an in memory operation. I don't think we need to measure that. editLog() is just like any other processing now. I haven't looked at the Stats etc yet. > Increase the concurrency of transaction logging to edits log > ------------------------------------------------------------ > > Key: HADOOP-1942 > URL: https://issues.apache.org/jira/browse/HADOOP-1942 > Project: Hadoop > Issue Type: Improvement > Components: dfs > Reporter: dhruba borthakur > Assignee: dhruba borthakur > Priority: Blocker > Fix For: 0.15.0 > > Attachments: transactionLogSync.patch, transactionLogSync2.patch, transactionLogSync3.patch, transactionLogSync4.patch > > > For some typical workloads, the throughput of the namenode is bottlenecked by the rate of transactions that are being logged into tghe edits log. In the current code, a batching scheme implies that all transactions do not have to incur a sync of the edits log to disk. However, the existing batch-ing scheme can be improved. > One option is to keep two buffers associated with edits file. Threads write to the primary buffer while holding the FSNamesystem lock. Then the thread release the FSNamesystem lock, acquires a new lock called the syncLock, swaps buffers, and flushes the old buffer to the persistent store. Since the buffers are swapped, new transactions continue to get logged into the new buffer. (Of course, the new transactions cannot complete before this new buffer is sync-ed). > This approach does a better job of batching syncs to disk, thus improving performance. -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.