You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by mu...@apache.org on 2012/08/02 08:59:18 UTC
[4/7] git commit: FLUME-1389. Flume gives opaque error if interceptor
type not specified.
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 <mu...@apache.org>
Authored: Thu Aug 2 06:33:18 2012 +0000
Committer: Mubarak Seyed <mu...@apache.org>
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);