FLUME-1389. Flume gives opaque error if interceptor type not specified. (Patrick Wendell via Hari Shreedharan)
git-svn-id: https://svn.apache.org/repos/asf/flume/trunk@1368362 13f79535-47bb-0310-9956-ffa450edef68 Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/e9e7f65a Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/e9e7f65a Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/e9e7f65a Branch: refs/heads/master Commit: e9e7f65a79775c4a0b1887f576fbbefc2b32207e Parents: 68ebd5f Author: Mubarak Seyed <[email protected]> Authored: Thu Aug 2 06:33:18 2012 +0000 Committer: Mubarak Seyed <[email protected]> Committed: Thu Aug 2 06:33:18 2012 +0000 ---------------------------------------------------------------------- .../org/apache/flume/channel/ChannelProcessor.java | 5 +++++ 1 files changed, 5 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/e9e7f65a/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);
