flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Deepak Subhramanian <deepak.subhraman...@gmail.com>
Subject Re: Json over netcat source
Date Fri, 11 Apr 2014 11:54:21 GMT
 Thanks Simon. I am also struggling with no luck. I tried using the latest
flume elastic search sink jar  build from 1.5SNAPSHOT ,but still no luck. I
will try to see if it is an issue with elastic search api . When I loaded
json using hive it loaded JSON properly. But we have to pass a property
es.input.json in hive.  Is there a way to pass the same in Flume.

CREATE EXTERNAL TABLE json (data STRING
<http://www.elasticsearch.org/guide/en/elasticsearch/hadoop/current/hive.html#CO25-1>)
STORED BY 'org.elasticsearch.hadoop.hive.EsStorageHandler'
TBLPROPERTIES('es.resource' = '...',
              'es.input.json` = 'yes'
<http://www.elasticsearch.org/guide/en/elasticsearch/hadoop/current/hive.html#CO25-2>);

Mime
View raw message