Hi George,
We need to add the payload column as well.Add the following
line in your config file :
hbase-agent.sinks.sink1.serializer.payloadColumn = col_name
Regards,
Mohammad Tariq
On Tue, Jul 17, 2012 at 8:23 PM, George Forman
<[email protected]> wrote:
> Hi all,
>
> Newbie here...I am trying to get flume ng to do a simple hbase sink.
> I have downloaded/installed flume-ng and configured it based on
> info found on the net. I don't see flume connecting to hbase.
> I am wondering what I could be missing? - Thanks
>
> Here is my configuration:
>
> hbase-agent.sources = tail
> hbase-agent.sinks = sink1
> hbase-agent.channels = ch1
>
> hbase-agent.sources.tail.type = exec
> hbase-agent.sources.tail.bind = pseudo
> hbase-agent.sources.tail.command = tail -F /tmp/test-flume.ens
> hbase-agent.sources.tail.channels = ch1
>
> hbase-agent.sinks.sink1.type = org.apache.flume.sink.hbase.HBaseSink
> hbase-agent.sinks.sink1.channel = ch1
> hbase-agent.sinks.sink1.table = ens
> hbase-agent.sinks.sink1.columnFamily = raw
> hbase-agent.sinks.sink1.column = event
> hbase-agent.sinks.sink1.serializer =
> org.apache.flume.sink.hbase.SimpleHbaseEventSerializer
> hbase-agent.channels.ch1.type = memory
>
>