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/06/28 23:00:06 UTC
git commit: FLUME-2110. Scribe Source must check if category is null
before inserting the headers.
Updated Branches:
refs/heads/trunk 4cb3b6d8e -> d66bf94b1
FLUME-2110. Scribe Source must check if category is null before inserting the headers.
(Hari Shreedharan 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/d66bf94b
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/d66bf94b
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/d66bf94b
Branch: refs/heads/trunk
Commit: d66bf94b1dd059bc7e4b1ff332be59a280498077
Parents: 4cb3b6d
Author: Mike Percy <mp...@apache.org>
Authored: Fri Jun 28 13:59:33 2013 -0700
Committer: Mike Percy <mp...@apache.org>
Committed: Fri Jun 28 13:59:33 2013 -0700
----------------------------------------------------------------------
.../main/java/org/apache/flume/source/scribe/ScribeSource.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flume/blob/d66bf94b/flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/ScribeSource.java
----------------------------------------------------------------------
diff --git a/flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/ScribeSource.java b/flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/ScribeSource.java
index b3a8de3..f9a14c1 100644
--- a/flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/ScribeSource.java
+++ b/flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/ScribeSource.java
@@ -149,7 +149,11 @@ public class ScribeSource extends AbstractSource implements
for (LogEntry entry : list) {
Map<String, String> headers = new HashMap<String, String>(1, 1);
- headers.put(SCRIBE_CATEGORY, entry.getCategory());
+ String category = entry.getCategory();
+
+ if (category != null) {
+ headers.put(SCRIBE_CATEGORY, category);
+ }
Event event = EventBuilder.withBody(entry.getMessage().getBytes(), headers);
events.add(event);