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