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 <[email protected]> Authored: Thu Apr 4 17:00:48 2013 -0500 Committer: Brock Noland <[email protected]> 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;
