FLUME-1389. Flume gives opaque error if interceptor type not specified. (Patrick Wendell via Hari Shreedharan)
Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/6681f0b8 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/6681f0b8 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/6681f0b8 Branch: refs/heads/cdh-1.2.0+24_intuit Commit: 6681f0b888b6438469e77fa212a8f25eca403fbf Parents: 8657b07 Author: Hari Shreedharan <[email protected]> Authored: Tue Jul 31 17:03:25 2012 -0700 Committer: Hari Shreedharan <[email protected]> Committed: Fri Sep 7 13:08:53 2012 -0700 ---------------------------------------------------------------------- .../org/apache/flume/channel/ChannelProcessor.java | 5 +++++ 1 files changed, 5 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/6681f0b8/flume-ng-core/src/main/java/org/apache/flume/channel/ChannelProcessor.java ---------------------------------------------------------------------- diff --git a/flume-ng-core/src/main/java/org/apache/flume/channel/ChannelProcessor.java b/flume-ng-core/src/main/java/org/apache/flume/channel/ChannelProcessor.java index 53bfac1..1cce137 100644 --- a/flume-ng-core/src/main/java/org/apache/flume/channel/ChannelProcessor.java +++ b/flume-ng-core/src/main/java/org/apache/flume/channel/ChannelProcessor.java @@ -100,6 +100,11 @@ public class ChannelProcessor implements Configurable { Context interceptorContext = new Context( interceptorContexts.getSubProperties(interceptorName + ".")); String type = interceptorContext.getString("type"); + if (type == null) { + LOG.error("Type not specified for interceptor " + interceptorName); + throw new FlumeException("Interceptor.Type not specified for " + + interceptorName); + } try { Interceptor.Builder builder = factory.newInstance(type); builder.configure(interceptorContext);
