You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by mp...@apache.org on 2013/03/15 01:29:46 UTC
git commit: FLUME-1882. Allow case-insensitive deserializer value for
SpoolDirectorySource.
Updated Branches:
refs/heads/trunk fc0b9b8cd -> 4d0814630
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/4d081463
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/4d081463
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/4d081463
Branch: refs/heads/trunk
Commit: 4d0814630b328f64f33627dcde12bf8d0b086ead
Parents: fc0b9b8
Author: Mike Percy <mp...@apache.org>
Authored: Thu Mar 14 17:28:59 2013 -0700
Committer: Mike Percy <mp...@apache.org>
Committed: Thu Mar 14 17:28:59 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/4d081463/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());
}