flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From br...@apache.org
Subject git commit: FLUME-1866: ChannelProcessor is not logging ChannelExceptions
Date Thu, 04 Apr 2013 22:01:51 GMT
Updated Branches:
  refs/heads/flume-1.4 24b73c074 -> 542f87e63


FLUME-1866: ChannelProcessor is not logging ChannelExceptions

(Roshan Naik 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/542f87e6
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/542f87e6
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/542f87e6

Branch: refs/heads/flume-1.4
Commit: 542f87e634cef2682eb71ecb52ddcd1cb9358110
Parents: 24b73c0
Author: Brock Noland <brock@apache.org>
Authored: Thu Apr 4 17:00:48 2013 -0500
Committer: Brock Noland <brock@apache.org>
Committed: Thu Apr 4 17:01:06 2013 -0500

----------------------------------------------------------------------
 .../flume/source/SequenceGeneratorSource.java      |    1 +
 1 files changed, 1 insertions(+), 0 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flume/blob/542f87e6/flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java
----------------------------------------------------------------------
diff --git a/flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java
b/flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java
index 3cb1ccf..0f85e87 100644
--- a/flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java
+++ b/flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java
@@ -96,6 +96,7 @@ public class SequenceGeneratorSource extends AbstractSource implements
     } catch (ChannelException ex) {
       counterGroup.incrementAndGet("events.failed");
       eventsSent -= i;
+      logger.error( getName() + " source could not write to channel.", ex);
     }
 
     return status;


Mime
View raw message