I'm trying to integrate apache-hive with elasticsearch. In order to achieve same i am following below steps
Created Table in hive:
CREATE TABLE scadapass (VENDOR string, Device string, Default_Password string, Port string, Device_Type string, Protocol string, Source string) row format delimited fields terminated by ',' stored as textfile;
loaded data from csv file
LOAD DATA LOCAL INPATH '/home/elk/Desktop/scadapass.csv' OVERWRITE INTO TABLE scadapass;
Added jar using hiveCLI
add jar /home/elk/Desktop/elasticsearch-hadoop-hive-6.1.3.jar
Now when i'm trying to create external table
CREATE EXTERNAL TABLE scadapass_es (VENDOR string, Device string, Default_Password string, Port string, Device_Type string, Protocol string, Source string) STORED BY 'org.elasticsearch.hadoop.hive.EsStorageHandler' TBLPROPERTIES('es.resource' = 'scadapass/pass');
code is through following error
FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. org.elasticsearch.hadoop.EsHadoopIllegalArgumentException: Cannot detect ES version - typically this happens if the network/Elasticsearch cluster is not accessible or when targeting a WAN/Cloud instance without the proper setting 'es.nodes.wan.only'
Please provide any help in similar direction.