You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "Shuang Wu (Created) (JIRA)" <ji...@apache.org> on 2011/11/08 20:27:51 UTC
[jira] [Created] (FLUME-845) Flume User Guide is inconsistent about
how collectorSink is translated into low level decorator/sinks.
Flume User Guide is inconsistent about how collectorSink is translated into low level decorator/sinks.
------------------------------------------------------------------------------------------------------
Key: FLUME-845
URL: https://issues.apache.org/jira/browse/FLUME-845
Project: Flume
Issue Type: Improvement
Components: Docs
Affects Versions: v0.9.4
Reporter: Shuang Wu
Priority: Minor
In User Guide 8.2.2, it states:
As of v0.9.3, a new more generic collector sink that better encapsulates the "collectorMagic" functionality. This allows you to specify arbitrary sinks (or mulitple sinks) using the flume specification language. So the equivalent of
collectorSink("xxx","yyy-%{rolltag}", 15000)
is now:
collector(15000) { escapedCustomDfs("xxx","yyy-%{rolltag}") }
while in section 8.2.3, it states:
collectorSink("xxx","yyy",15000) is also a bit complicated with some custom decorators to handle acks. Under the covers however, it depends on a roller with a escapedCustomDfsSink inside of it.
roll(15000) { collectorMagic escapedCustomDfs("xxx", "yyy-%{rolltag}") }
There are two problems here:
- make it clear which statement describes the current behavior (0.9.4), and remove the other one.
- the first statement is wrong in that it includes %{rolltag} in the collectorSink configuration, actually, %{rolltag} is added by Flume automatically.
--
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