You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "Will McQueen (JIRA)" <ji...@apache.org> on 2012/07/17 19:23:34 UTC
[jira] [Updated] (FLUME-1376) StaticInterceptor doc update
[ https://issues.apache.org/jira/browse/FLUME-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Will McQueen updated FLUME-1376:
--------------------------------
Attachment: FLUME-1376.patch
> StaticInterceptor doc update
> ----------------------------
>
> Key: FLUME-1376
> URL: https://issues.apache.org/jira/browse/FLUME-1376
> Project: Flume
> Issue Type: Bug
> Components: Docs
> Affects Versions: v1.3.0
> Reporter: Will McQueen
> Assignee: Will McQueen
> Priority: Minor
> Fix For: v1.3.0
>
> Attachments: FLUME-1376.patch
>
>
> JavaDocs for StaticInterceptor need to be updated from this:
> * agent.sources.r1.interceptors.i1.type = timestamp
> ..to this:
> * agent.sources.r1.interceptors.i1.type = static
> Confirmed successful output by testing with this config file:
> agent.channels = c1
> agent.sources = r1
> agent.sinks = k1
> agent.channels.c1.type = MEMORY
> agent.sources.r1.channels = c1
> agent.sources.r1.type = SEQ
> agent.sources.r1.interceptors = i1
> agent.sources.r1.interceptors.i1.type = static
> agent.sources.r1.interceptors.i1.preserveExisting = false
> agent.sources.r1.interceptors.i1.key = datacenter
> agent.sources.r1.interceptors.i1.value= NYC_01
> agent.sinks.k1.channel = c1
> agent.sinks.k1.type = LOGGER
> ...and some sample output was:
> 2012-07-17 10:13:17,981 INFO source.SequenceGeneratorSource: Sequence generator source starting
> 2012-07-17 10:13:17,997 INFO sink.LoggerSink: Event: { headers:{datacenter=NYC_01} body: 30 0 }
> 2012-07-17 10:13:17,998 INFO sink.LoggerSink: Event: { headers:{datacenter=NYC_01} body: 31 1 }
> 2012-07-17 10:13:17,998 INFO sink.LoggerSink: Event: { headers:{datacenter=NYC_01} body: 32 2 }
> 2012-07-17 10:13:17,999 INFO sink.LoggerSink: Event: { headers:{datacenter=NYC_01} body: 33 3 }
> 2012-07-17 10:13:17,999 INFO sink.LoggerSink: Event: { headers:{datacenter=NYC_01} body: 34 4 }
> Unless requested, I'll just attach the patch here rather than uploading to ReviewBoard, since it's a very minor update.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira