You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flume.apache.org by AD <st...@gmail.com> on 2011/10/11 00:42:09 UTC

E2E Warnings

Hello,

 I keep getting these warnings when running E2E , are these problematic
(cloudera 0.9.4 CDH3u1 flume build) ?

2011-10-10 18:36:35,383 [logicalNode collector-23] WARN core.Event: Tag node
not found
2011-10-10 18:36:35,383 [logicalNode collector-23] WARN
endtoend.AckChecksumChecker: check sum does not match!

my config is

agent:
  source: tail('/var/log/apache.log")
  sink: agentE2ESink("collector",35853)

collector:
  source: collectorSource(35853)
  sink: regexAll("^([0-9.]+)\\s\\[([0-9a-zA-z\\/:
-]+)\\]\\s([A-Z]+)\\s([a-zA-Z0-9:]+)\\s\"([^\\s]+)\"\\s([0-9]+)\\s([0-9]+)\\s\"([^\\s]+)\"\\s\"([a-zA-Z0-9\\/()_
-;]+)\"\\s(hit|miss)\\s([0-9.]+)","ss_remote_host","ss_request_date","ss_request_method","ss_request_host","ss_request_url","ss_response_status","ss_response_bytes","ss_referrer","ss_user_agent","ss_cache_hitmiss","ss_origin_firstbyte")
format("%{nanos}:") split(":", 0, "ss_") format("%{node}:")
split(":",0,"ss_node") digest("MD5","ss_md5") collector(10000) {
attr2hbase("apache_logs","f1","","ss_") }