Problème lors de l'écriture dans elasticsearch à l'aide d'es-hadoop

Question

Récupère cette exception lorsque j'essaie d'écrire dans Elasticsearch en utilisant le programme mapreduce avec es-hadoop. J'essaie d'écrire à index = employee et type = basic qui existe déjà dans mon cluster Elasticsearch.

Ma trace de la pile: -

Exception in thread "main" org.elasticsearch.hadoop.EsHadoopIllegalArgumentException: Aucune ressource [ 'es.resource'] (index/requête/emplacement) spécifié à org.elasticsearch.hadoop.util.Assert.hasText (Assert.java:30) au 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) au org.apache.hadoop.mapreduce.JobSubmitter.submitJobInternal (JobSubmitter.java:139) à org.apache.hadoop.mapreduce.Job $ 10.run (Job.java:1290) à org.apache.hadoop.mapreduce.Job $ 10.run (Job.java:1287) à java.security.AccessController.doPrivileged (méthode native) à javax.security.auth.Subject.doAs (Subject.java: 422) à org.apache.hadoop.security.UserGroupInformation.doAs (UserGroupInformation.java:1657) à org.apache.hadoop.mapreduce.Job.submit (Job.java:1287) à org.apache.hadoop. mapreduce.Job.waitForCompletion (Job.java:1308) à com.mstack.mapreduce.DIGDriver.main (DIGDriver.java:22) à sun.reflect.NativeMethodA ccessorImpl.invoke0 (méthode native) à sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62) à sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43) à java.lang.reflect.Method. appelez (Method.java:497) au org.apache.hadoop.util.RunJar.run (RunJar.java:221) au org.apache.hadoop.util.RunJar.main (RunJar.java:136)

classe Driver: -

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

Résolu moi-même en changeant les configs: -

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