Return-Path: Delivered-To: apmail-hadoop-chukwa-commits-archive@minotaur.apache.org Received: (qmail 47638 invoked from network); 16 Apr 2009 22:11:21 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 16 Apr 2009 22:11:21 -0000 Received: (qmail 43798 invoked by uid 500); 16 Apr 2009 22:11:21 -0000 Delivered-To: apmail-hadoop-chukwa-commits-archive@hadoop.apache.org Received: (qmail 43787 invoked by uid 500); 16 Apr 2009 22:11:21 -0000 Mailing-List: contact chukwa-commits-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-commits@hadoop.apache.org Received: (qmail 43777 invoked by uid 99); 16 Apr 2009 22:11:21 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 16 Apr 2009 22:11:21 +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.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 16 Apr 2009 22:11:12 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 9106023888AF; Thu, 16 Apr 2009 22:10:51 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r765789 - /hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SeqFileWriter.java Date: Thu, 16 Apr 2009 22:10:51 -0000 To: chukwa-commits@hadoop.apache.org From: eyang@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20090416221051.9106023888AF@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: eyang Date: Thu Apr 16 22:10:51 2009 New Revision: 765789 URL: http://svn.apache.org/viewvc?rev=765789&view=rev Log: CHUKWA-139. Rewrite collector bail out code. (Cheng Zhang via Eric Yang) Modified: hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SeqFileWriter.java Modified: hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SeqFileWriter.java URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SeqFileWriter.java?rev=765789&r1=765788&r2=765789&view=diff ============================================================================== --- hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SeqFileWriter.java (original) +++ hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SeqFileWriter.java Thu Apr 16 22:10:51 2009 @@ -112,23 +112,14 @@ try { fs = FileSystem.get(new URI(fsname), conf); if (fs == null) { - log.error("can't connect to HDFS at " + fs.getUri()); - return; - } else - log.info("filesystem is " + fs.getUri()); - } catch (IOException e) { - log - .error( - "can't connect to HDFS, trying default file system instead (likely to be local)", - e); - try { - fs = FileSystem.get(conf); - } catch (IOException err) { - log.error("can't connect to default file system either", e); - } - } catch (URISyntaxException e) { - log.error("problem generating new URI from config setting"); - return; + log.error("can't connect to HDFS at " + fs.getUri() + " bail out!"); + DaemonWatcher.bailout(-1); + } + } catch (Throwable e) { + log.error( + "can't connect to HDFS, trying default file system instead (likely to be local)", + e); + DaemonWatcher.bailout(-1); } // Setup everything by rotating