es-hadoop kullanarak elasticsearch yazarken sorun

Question

Bu istisnayı, es-hadoop ile mapreduce programını kullanarak Elasticsearch'e yazmaya çalıştığımda alıyorum. dizini = çalışanını yazmaya çalışıyorum ve şu an Elasticsearch kümemde bulunan temel yazın.

My yığıtı: -: [ 'es.resource'] (göstergesi/sorgu/konum) belirtilen Resim kaynak "ana" org.elasticsearch.hadoop.EsHadoopIllegalArgumentException iplik

durum org.elasticsearch.hadoop.mr.EsOutputFormat de org.elasticsearch.hadoop.util.Assert.hasText org.elasticsearch.hadoop.mr.EsOutputFormat.init (EsOutputFormat.java:257) 'den (Assert.java:30) .checkOutputSpecs (EsOutputFormat.java:233) , org.apache.hadoop.mapreduce.JobSubmitter.chec kSpecs (JobSubmitter.java:266) org.apache.hadoop.mapreduce.JobSubmitter.submitJobInternal (JobSubmitter.java:139) adresinden org.apache.hadoop.mapreduce.Job $ 10.run (Job.java:1290) org.apache.hadoop.mapreduce.Job $ 10.run (Job.java:1287) at java.security.AccessController.doPrivileged (Yerel Yöntem) at javax.security.auth.Subject.doAs (Subject.java: 422) org.apache.hadoop adresinde org.apache.hadoop.security.UserGroupInformation.doAs (UserGroupInformation.java:1657) adresinde org.apache.hadoop.mapreduce.Job.submit (Job.java:1287) adresinden edinilebilir. com.mstack.mapreduce.DIGDriver.main (DIGDriver.java:22) adresindeki mapreduce.Job.waitForCompletion (Job.java:1308) sun.reflect.NativeMethodA ccessorImpl.invoke0 sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method de de sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62) 'den (Ana Yöntemi) . org.apache.hadoop.util.RunJar.main (RunJar.java:136) en org.apache.hadoop.util.RunJar.run (RunJar.java:221) de çağırmak (Method.java:497)

Sürücü sınıfı: -

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

Yapıları değiştirerek kendimi çözdüm: -

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