Updated Branches: refs/heads/trunk dd1880231 -> 1c84ab3e4
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/1c84ab3e Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/1c84ab3e Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/1c84ab3e Branch: refs/heads/trunk Commit: 1c84ab3e4b1ed63d0578e1f439fba38a0b841d33 Parents: dd18802 Author: Hari Shreedharan <[email protected]> Authored: Tue Jul 31 17:03:25 2012 -0700 Committer: Hari Shreedharan <[email protected]> Committed: Tue Jul 31 17:03:25 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/1c84ab3e/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);
