Hello Rahul,
My apologies for my typo in your name in my previous reply.
How about trying fanout to console to narrow down to the cause, to see
whether it is from agent or collector?
say,
try 1. tail("/tmp/test03")|[agentSink("localhost",35853), console] to
check data duplication in agent, or you can use "dump" in collector
try 2. {regexAll("(\\w+)\\t+(\\w+)\\t+(\\w+)", "row", "data1", "data2")
=> [hbase("ft02", "%{row}", "cf1", "col", "%{data1}", "cf2", "coll",
"%{data2}"),console]} to check data duplication before hbaseSink in
collector
On 6/14/12 10:18 PM, Rahul Patodi wrote:
> {regexAll("(\\w+)\\t+(\\w+)\\t+(\\w+)", "row", "data1", "data2") =>
> hbase("ft02", "%{row}", "cf1", "col", "%{data1}", "cf2", "coll",
> "%{data2}")}
--
----------------------------
장정식 / jsj...@gruter.com
(주)그루터, R&D팀 수석
www.gruter.com
Cloud, Search and Social
----------------------------
