es-hadoopを使用してelasticsearchに書き込むときの問題

Question

es-hadoopでmapreduceプログラムを使用してElasticsearchに書き込もうとしているときにこの例外が発生しています。 index = employeeとtype = basicに書き込もうとしていますが、既にElasticsearchクラスタに存在しています。

私のスタックトレース： - ： で指定されていませんリソース [ 'es.resource']（インデックス/クエリ/場所）スレッド内

例外 "メイン" org.elasticsearch.hadoop.EsHadoopIllegalArgumentException org.elasticsearch.hadoop.util.Assert.hasText（Assert.java:30）at org.elasticsearch.hadoop.mr.EsOutputFormat.init（EsOutputFormat.java:257） at org.elasticsearch.hadoop.mr.EsOutputFormat .checkOutputSpecs（EsOutputFormat.java:233） at org.apache.hadoop.mapreduce.JobSubmitter.chec kSpecs（JobSubmitter.java:266） at org.apache.hadoop.mapreduce.JobSubmitter.submitJobInternal（JobSubmitter.java:139） at org.apache.hadoop.mapreduce.Job $ 10.run（Job.java:1290）で org.apache.hadoop.mapreduce.Job $ 10.run（Job.java:1287） java.security.AccessController.doPrivileged（ネイティブメソッド） でjavax.security.auth.Subject.doAs（Subject.java： 422）at org.apache.hadoop.security.UserGroupInformation.doAs（UserGroupInformation.java:1657） at org.apache.hadoop.mapreduce.Job.submit（Job.java:1287）at org.apache.hadoop。 mapreduce.Job.waitForCompletion（Job.java:1308）at com.mstack.mapreduce.DIGDriver.main（DIGDriver.java:22） sun.reflect.NativeMethodA ccessorImpl.invoke0 sun.reflect.DelegatingMethodAccessorImpl.invoke（DelegatingMethodAccessorImpl.java:43）java.lang.reflect.Methodオブジェクトで でsun.reflect.NativeMethodAccessorImpl.invoke（NativeMethodAccessorImpl.java:62）での（ネイティブメソッド） 。 org.apache.hadoop.util.RunJar.main（RunJar.java:136）で org.apache.hadoop.util.RunJar.run（RunJar.java:221）で呼び出す（Method.java:497）

ドライバー・クラス： -

Configuration conf = new Configuration(); 
Job job = Job.getInstance(conf, "es-hadoop"); 
job.setJarByClass(DIGDriver.class); 
conf.set("es.nodes", "localhost:9200"); 
conf.set("es.port", "9200"); 
conf.set("es.resource", "employee/basic"); 
job.setNumReduceTasks(0); 
job.setOutputFormatClass(EsOutputFormat.class); 
job.setMapperClass(DIGMapper.class); 
job.setMapOutputValueClass(MapWritable.class); 
conf.setBoolean("mapreduce.map.speculative", false); 
conf.setBoolean("mapreduce.reduce.speculative", false); 
boolean status = job.waitForCompletion(true); 
if (status) { 
System.exit(0); 
} else { 
System.out.println("Job Failed : Some error!"); 
System.exit(1); 
} 

Answer 1

設定を変更して解決しました： -

conf.set("es.nodes", "localhost"); 
conf.set("es.port", "9200");