Updated Branches: refs/heads/flume-1.4 eb17987a6 -> 2479bbfa8
FLUME-1924. Bug in serializer context parsing in RollingFileSink (Mike Percy 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/2479bbfa Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/2479bbfa Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/2479bbfa Branch: refs/heads/flume-1.4 Commit: 2479bbfa8aeb2499d7372ea1e88c10697c6cbea1 Parents: eb17987 Author: Hari Shreedharan <[email protected]> Authored: Fri Jun 21 15:19:35 2013 -0700 Committer: Hari Shreedharan <[email protected]> Committed: Fri Jun 21 15:20:11 2013 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/flume/sink/RollingFileSink.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/2479bbfa/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java ---------------------------------------------------------------------- diff --git a/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java b/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java index 2677531..9cb3370 100644 --- a/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java +++ b/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java @@ -78,7 +78,8 @@ public class RollingFileSink extends AbstractSink implements Configurable { serializerType = context.getString("sink.serializer", "TEXT"); serializerContext = - new Context(context.getSubProperties(EventSerializer.CTX_PREFIX)); + new Context(context.getSubProperties("sink." + + EventSerializer.CTX_PREFIX)); Preconditions.checkArgument(directory != null, "Directory may not be null"); Preconditions.checkNotNull(serializerType, "Serializer type is undefined");
