Сбой отправки задания Hive MapReduce Целью является каталог

Я играл с Hadoop и его дочерними проектами, и у меня было несколько проблем на этом пути, но я, наконец, столкнулся с одной, на которую не могу найти ответ:

У меня есть таблица кустов, хранящаяся на hdfs в виде текстового файла с разделителями табуляции. И я могу сделать базовый выбор в таблице, но как только я немного усложняю запрос, куст превращает его в задание по сокращению карты, которое завершается с ошибкой со следующей трассировкой стека.

Рассматриваемая папка существует в dfs, по крайней мере, в части «/tmp/hadoop-yarn/staging», и независимо от того, на что я устанавливаю ее разрешения, hive или hadoop сбрасывает их при отправке задания. Что действительно беспокоит, так это то, что полный путь выглядит как сгенерированное имя папки, так почему же у программного обеспечения возникают проблемы с чем-то, что оно сгенерировало самостоятельно? Почему проблема в том, что путь является каталогом? И каким он должен быть?

Изменить: вот таблица, с которой я работаю, и запрос, который я пытаюсь запустить: Запрос: select * from hive_flow_details where node_id = 100 limit 10;

Стол:

col_name data_type идентификатор комментария bigint None
flow_versions_id int None
node_id int None
node_name string None

Имейте в виду, что это происходит с любым uery, который я пытаюсь использовать, который имеет какое-либо предложение where, поскольку hive переводит это в задание MR.

В конце концов я пришел к этой проблеме. Я обнаружил конфликтующие банки в своем пути к классам, которые я очистил, и с тех пор у меня не было проблем.


person Menster    schedule 29.11.2013    source источник
comment
11.13.29 08:31:00 ОШИБКА security.UserGroupInformation: PriviledgedActionException as:hduser (auth:SIMPLE) причина:java.io.IOException: Target /tmp/hadoop-> > yarn/staging/hduser/.staging/job_1385633903169_0013 /libjars/lib/lib — это каталог 11.13.29 08:31:00 ОШИБКА security.UserGroupInformation: PriviledgedActionException as:hduser (auth:SIMPLE) причина:java.io.IOException: Target /tmp/hadoop-yarn/staging /hduser/.staging/job_1385633903169_0013/libjars/lib/lib — это каталог java.io.IOException: Target /tmp/hadoop-yarn/staging/hduser/.staging/job_1385633903169_0013/libjars/lib/lib — это каталог в org. apache.hadoop.fs.FileUtil.checkDest(FileUtil.java:500) в org.apache.hadoop.fs.FileUtil.checkDest(FileUtil.java:502) в org.apache.hadoop.fs.FileUtil.copy(FileUtil. java:348) в org.apache.hadoop.fs.FileUtil.copy(FileUtil.java:338) в org.apache.hadoop.fs.FileUtil.copy(FileUtil.java:289) в org.apache.hadoop.mapreduce .JobSubmitter. copyRemoteFiles(JobSubmitter.java:139) в org.apache.hadoop.mapreduce.JobSubmitter.copyAndConfigureFiles(JobSubmitter.java:212) в org.apache.hadoop.mapreduce.JobSubmitter.copyAndConfigureFiles(JobSubmitter.java:300) в org.apache .hadoop.mapreduce.JobSubmitter.submitJobInternal(JobSubmitter.java:387) в org.apache.hadoop.mapreduce.Job$10.run(Job.java:1268) в org.apache.hadoop.mapreduce.Job$10.run(Job .java:1265) в java.security.AccessController.doPrivileged(собственный метод) в javax.security.auth.Subject.doAs(Subject.java:415) в org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java :1491) на org.apache.hadoop.mapreduce.Job.submit(Job.java:1265) на org.apache.hadoop.mapred.JobClient$1.run(JobClient.java:562) на org.apache.hadoop.mapred .JobClient$1.run(JobClient.java:557) в java.security.AccessController.doPrivileged(собственный метод) в javax.security.auth.Subject.doAs(Subject.java:415) в org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1491) в org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient. java:557) в org.apache.hadoop.mapred.JobClient.submitJob(JobClient.java:548) в org.apache.hadoop.hive.ql.exec.mr.ExecDriver.execute(ExecDriver.java:425) в org. .apache.hadoop.hive.ql.exec.mr.MapRedTask.execute(MapRedTask.java:144) в org.apache.hadoop.hive.ql.exec. Task.executeTask(Task.java:151) в org.apache.hadoop.hive.ql.exec.TaskRunner.runSequential(TaskRunner.java:65) в org.apache.hadoop.hive.ql.Driver.launchTask(Driver. java:1414) в org.apache.hadoop.hive.ql.Driver.execute(Driver.java:1192) в org.apache.hadoop.hive.ql.Driver.runInternal(Driver.java:1020) в org.apache .hadoop.hive.ql.Driver.run(Driver.java:888) в org.apache.hadoop.hive.cli.CliDriver.processLocalCmd(CliDriver.java:259) в org.apache.hadoop.hive.cli.CliDriver .processCmd(CliDriver.java:216) в org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:413) в org.apache.hadoop.hive.cli.CliDriver.executeDriver(CliDriver.java:781) ) в org.apache.hadoop.hive.cli.CliDriver.run(CliDriver.java:675) в org.apache.hadoop.hive.cli.CliDriver.main(CliDriver.java:614) в sun.reflect.NativeMethodAccessorImpl. invoke0 (собственный метод) в sun.reflect.NativeMet hodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) в sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) в java.lang.reflect.Method.invoke(Method.java:606) в org.apache.hadoop.util .RunJar.main(RunJar.java:212) Ошибка отправки задания с исключением 'java.io.IOException(Target /tmp/hadoop-yarn/staging/hduser/.staging/job_1385633903169_0013/libjars/lib/lib является каталогом)' 11.13.29 08:31:00 ОШИБКА exec.Task: отправка задания не удалась с исключением 'java.io.IOException (цель /tmp/hadoop-yarn/staging/hduser/.staging/job_1385633903169_0013/libjars/lib/lib is a directory)' java.io.IOException: Target /tmp/hadoop-yarn/staging/hduser/.staging/job_1385633903169_0013/libjars/lib/lib — это каталог в org.apache.hadoop.fs.FileUtil.checkDest(FileUtil. java:500) по адресу org.apache.hadoop.fs.FileUtil.checkDest(FileUtil.java:502) по адресу org.apache.hadoop.fs.FileUtil.copy(FileUtil.java:348) по адресу org.a pache.hadoop.fs.FileUtil.copy(FileUtil.java:338) в org.apache.hadoop.fs.FileUtil.copy(FileUtil.java:289) в org.apache.hadoop.mapreduce.JobSubmitter.copyRemoteFiles(JobSubmitter. java:139) по адресу org.apache.hadoop.mapreduce.JobSubmitter.copyAndConfigureFiles(JobSubmitter.java:212) по адресу org.apache.hadoop.mapreduce.JobSubmitter.copyAndConfigureFiles(JobSubmitter.java:300) по адресу org.apache.hadoop.mapreduce .JobSubmitter.submitJobInternal(JobSubmitter.java:387) на org.apache.hadoop.mapreduce. Job$10.run(Job.java:1268) в org.apache.hadoop.mapreduce.Job$10.run(Job.java:1265) в java.security.AccessController.doPrivileged(собственный метод) в javax.security.auth. Subject.doAs(Subject.java:415) в org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1491) в org.apache.hadoop.mapreduce.Job.submit(Job.java:1265) в org. .apache.hadoop.mapred.JobClient$1.run(JobClient.java:562) в org.apache.hadoop.mapred.JobClient$1.run(JobClient.java:557) в java.security.AccessController.doPrivileged(собственный метод) в javax.security.auth.Subject.doAs(Subject.java:415) в org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1491) в org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient .java:557) в org.apache.hadoop.mapred.JobClient.submitJob(JobClient.java:548) в org.apache.hadoop.hive.ql.exec.mr.ExecDriver.ex ecute(ExecDriver.java:425) в org.apache.hadoop.hive.ql.exec.mr.MapRedTask.execute(MapRedTask.java:144) в org.apache.hadoop.hive.ql.exec.Task.executeTask( Task.java:151) в org.apache.hadoop.hive.ql.exec.TaskRunner.runSequential(TaskRunner.java:65) в org.apache.hadoop.hive.ql.Driver.launchTask(Driver.java:1414) в org.apache.hadoop.hive.ql.Driver.execute(Driver.java:1192) в org.apache.hadoop.hive.ql.Driver.runInternal(Driver.java:1020) в org.apache.hadoop.hive .ql.Driver.run(Driver.java:888) в org.apache.hadoop.hive.cli.CliDriver.processLocalCmd(CliDriver.java:259) в org.apache.hadoop.hive.cli.CliDriver.processCmd(CliDriver .java:216) по адресу org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:413) по адресу org.apache.hadoop.hive.cli.CliDriver.executeDriver(CliDriver.java:781) по адресу org. apache.hadoop.hive.cli.CliDriver.run(CliDriver.java:675) в org.apache. hadoop.hive.cli.CliDriver.main(CliDriver.java:614) в sun.reflect.NativeMethodAccessorImpl.invoke0(собственный метод) в sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) в sun.reflect.DelegatingMethodAccessorImpl. invoke(DelegatingMethodAccessorImpl.java:43) в java.lang.reflect.Method.invoke(Method.java:606) в org.apache.hadoop.util.RunJar.main(RunJar.java:212)   -  person vishnu viswanath    schedule 29.11.2013


Ответы (1)


Можете ли вы опубликовать запрос, который вы пытаетесь запустить?

person Menster    schedule 02.12.2013