2016-04-13 1 views
1

Получается это исключение, когда я пытаюсь написать Elasticsearch, используя программу mapreduce с es-hadoop. Я пытаюсь написать index = employee и type = basic, который уже существует в моем кластере Elasticsearch.Проблема при записи в elasticsearch с использованием es-hadoop

Мой трассировки стека: -

Исключение в потоке "главный" org.elasticsearch.hadoop.EsHadoopIllegalArgumentException: Нет ресурсов [ 'es.resource'] (индекс/запрос/место), указанный в org.elasticsearch.hadoop.util.Assert.hasText (Assert.java:30) по адресу org.elasticsearch.hadoop.mr.EsOutputFormat.init (EsOutputFormat.java:257) по адресу org.elasticsearch.hadoop.mr.EsOutputFormat .checkOutputSpecs (EsOutputFormat.java:233) по адресу 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) at org.apache.hadoop.mapreduce.Job $ 10.run (Job.java:1287) в java.security.AccessController.doPrivileged (собственный метод) в 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 (Родной метод) при sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62) на sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43) в java.lang.reflect.Method. invoke (Method.java:497) в org.apache.hadoop.util.RunJar.run (RunJar.java:221) в org.apache.hadoop.util.RunJar.main (RunJar.java:136)

класс

Водитель: -

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); 
} 

ответ

1

Разрешено путем изменения конфигураций: -

conf.set("es.nodes", "localhost"); 
conf.set("es.port", "9200"); 
Смежные вопросы