Получается это исключение, когда я пытаюсь написать 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);
}