Updated Branches: refs/heads/flume-1.4 6b407e1a0 -> 84ba0bd84
FLUME-1882. Allow case-insensitive deserializer value for SpoolDirectorySource. (Will McQueen via Mike Percy) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/84ba0bd8 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/84ba0bd8 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/84ba0bd8 Branch: refs/heads/flume-1.4 Commit: 84ba0bd84f42c08b6b304821bb2b10fafccc9fba Parents: 6b407e1 Author: Mike Percy <[email protected]> Authored: Thu Mar 14 17:28:59 2013 -0700 Committer: Mike Percy <[email protected]> Committed: Thu Mar 14 17:29:39 2013 -0700 ---------------------------------------------------------------------- .../apache/flume/source/SpoolDirectorySource.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/84ba0bd8/flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySource.java ---------------------------------------------------------------------- diff --git a/flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySource.java b/flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySource.java index 698b906..641b5c6 100644 --- a/flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySource.java +++ b/flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySource.java @@ -130,7 +130,7 @@ Configurable, EventDrivenSource { // spooling directory source, which did not support deserializers Integer bufferMaxLineLength = context.getInteger(BUFFER_MAX_LINE_LENGTH); if (bufferMaxLineLength != null && deserializerType != null && - deserializerType.equals(DEFAULT_DESERIALIZER)) { + deserializerType.equalsIgnoreCase(DEFAULT_DESERIALIZER)) { deserializerContext.put(LineDeserializer.MAXLINE_KEY, bufferMaxLineLength.toString()); }
