Return-Path: Delivered-To: apmail-hadoop-chukwa-dev-archive@minotaur.apache.org Received: (qmail 70812 invoked from network); 28 May 2009 23:13:57 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 28 May 2009 23:13:57 -0000 Received: (qmail 54749 invoked by uid 500); 28 May 2009 23:14:10 -0000 Delivered-To: apmail-hadoop-chukwa-dev-archive@hadoop.apache.org Received: (qmail 54733 invoked by uid 500); 28 May 2009 23:14:10 -0000 Mailing-List: contact chukwa-dev-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: chukwa-dev@hadoop.apache.org Delivered-To: mailing list chukwa-dev@hadoop.apache.org Received: (qmail 54723 invoked by uid 99); 28 May 2009 23:14:10 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 28 May 2009 23:14:10 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.140] (HELO brutus.apache.org) (140.211.11.140) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 28 May 2009 23:14:06 +0000 Received: from brutus (localhost [127.0.0.1]) by brutus.apache.org (Postfix) with ESMTP id 8EC85234C004 for ; Thu, 28 May 2009 16:13:45 -0700 (PDT) Message-ID: <1710664285.1243552425570.JavaMail.jira@brutus> Date: Thu, 28 May 2009 16:13:45 -0700 (PDT) From: "Cheng (JIRA)" To: chukwa-dev@hadoop.apache.org Subject: [jira] Issue Comment Edited: (CHUKWA-267) Collect shuffling information from userlogs/syslog In-Reply-To: <797354348.1243471785937.JavaMail.jira@brutus> MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/CHUKWA-267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12714213#action_12714213 ] Cheng edited comment on CHUKWA-267 at 5/28/09 4:13 PM: ------------------------------------------------------- Not sure if I understand the code correctly, below are some questions I have. 1. chukwaClientIsNull and chukwaLock. I guess the correct order might be
        synchronized (chukwaLock) {
            chukwaClientIsNull = false;
            if (chukwaClientIsNull) {
                 ..............
            }
        }
instead of, if (chukwaClientIsNull) { synchronized (chukwaLock) { chukwaClientIsNull = false; ........... } } 2. Currently in the patch, the chukwaClient is created in method TaskLogAppender.subAppend. If the agent is not running, will the block inside "synchronized (chukwaLock)" called many times? If yes, our appender may impact the task track and then we may need a background thread to create chukwaClient. If no, can we move the code into constructor? Thanks, Cheng -Cheng was (Author: zhangyongjiang): Not sure if I understand the code correctly, below are some questions I have. 1. chukwaClientIsNull and chukwaLock. I guess the correct order might be synchronized (chukwaLock) { chukwaClientIsNull = false; if (chukwaClientIsNull) { .............. } } instead of, if (chukwaClientIsNull) { synchronized (chukwaLock) { chukwaClientIsNull = false; ........... } } 2. Currently in the patch, the chukwaClient is created in method TaskLogAppender.subAppend. If the agent is not running, will the block inside "synchronized (chukwaLock)" called many times? If yes, our appender may impact the task track and then we may need a background thread to create chukwaClient. If no, can we move the code into constructor? Thanks, Cheng -Cheng > Collect shuffling information from userlogs/syslog > -------------------------------------------------- > > Key: CHUKWA-267 > URL: https://issues.apache.org/jira/browse/CHUKWA-267 > Project: Hadoop Chukwa > Issue Type: New Feature > Components: data collection > Affects Versions: 0.2.0 > Environment: Redhat EL 5.1, Java 6 > Reporter: Eric Yang > Assignee: Eric Yang > Fix For: 0.1.2, 0.2.0 > > Attachments: CHUKWA-267.patch > > > Hadoop uses a customized version of log4j appender (org.apache.hadoop.mapred.TaskLogAppender) for tasks. Shuffling information is written to userlogs/syslog by TaskLogAppender. For chukwa to collect shuffling information, we need to write a new TaskLogAppender to do this. -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.