Return-Path: X-Original-To: apmail-flume-commits-archive@www.apache.org Delivered-To: apmail-flume-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id A0546E43B for ; Mon, 28 Jan 2013 01:37:07 +0000 (UTC) Received: (qmail 40244 invoked by uid 500); 28 Jan 2013 01:37:06 -0000 Delivered-To: apmail-flume-commits-archive@flume.apache.org Received: (qmail 40178 invoked by uid 500); 28 Jan 2013 01:37:06 -0000 Mailing-List: contact commits-help@flume.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flume.apache.org Delivered-To: mailing list commits@flume.apache.org Received: (qmail 40165 invoked by uid 99); 28 Jan 2013 01:37:06 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 28 Jan 2013 01:37:06 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id EA9808262B6; Mon, 28 Jan 2013 01:37:05 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: brock@apache.org To: commits@flume.apache.org X-Mailer: ASF-Git Admin Mailer Subject: git commit: FLUME-1880: Double-logging of created HDFS files Message-Id: <20130128013705.EA9808262B6@tyr.zones.apache.org> Date: Mon, 28 Jan 2013 01:37:05 +0000 (UTC) Updated Branches: refs/heads/trunk dca895d80 -> f5d31f7a6 FLUME-1880: Double-logging of created HDFS files (Mike Percy via Brock Noland) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/f5d31f7a Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/f5d31f7a Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/f5d31f7a Branch: refs/heads/trunk Commit: f5d31f7a68e87c8bcc9ca5d43e5a29180d35b47d Parents: dca895d Author: Brock Noland Authored: Sun Jan 27 19:36:34 2013 -0600 Committer: Brock Noland Committed: Sun Jan 27 19:36:34 2013 -0600 ---------------------------------------------------------------------- .../org/apache/flume/sink/hdfs/BucketWriter.java | 2 -- 1 files changed, 0 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/f5d31f7a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java b/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java index 3f31ef2..1ff1984 100644 --- a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java +++ b/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java @@ -227,12 +227,10 @@ class BucketWriter { // Need to get reference to FS using above config before underlying // writer does in order to avoid shutdown hook & IllegalStateExceptions fileSystem = new Path(bucketPath).getFileSystem(config); - LOG.info("Creating " + bucketPath); writer.open(bucketPath); } else { // need to get reference to FS before writer does to avoid shutdown hook fileSystem = new Path(bucketPath).getFileSystem(config); - LOG.info("Creating " + bucketPath); writer.open(bucketPath, codeC, compType); } } catch (Exception ex) {