You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by hs...@apache.org on 2012/08/01 02:06:47 UTC
git commit: FLUME-1389. Flume gives opaque error if interceptor type
not specified.
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 <hs...@apache.org>
Authored: Tue Jul 31 17:03:25 2012 -0700
Committer: Hari Shreedharan <hs...@apache.org>
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);