Выполнение запроса JOIN из Hive 1.0.0 на HBase 0.98

Я получаю следующее исключение, когда выполняю запрос JOIN, используя Hive 1.0.0 в таблице HBase (0.98). Простые запросы SELECT работают нормально. Кроме того, упомянутый файл jar присутствует в указанном месте.

2015-04-24 12:24:37,114 ОШИБКА [основная]: ql.Driver (SessionState.java:printError(833)) — FAILED: ошибка выполнения, код возврата 1 из org.apache.hadoop.hive.ql.exec. mr.MapRedTask

Hadoop-mapreduce-client-core-2.6.0.jar ищется в HDFS.


person fullars    schedule 24.04.2015    source источник


Ответы (1)


hdfs://localhost:9000/ — это адрес hdfs Hadoop. Вы можете либо указать свой домашний путь, либо загрузить файл jar в hdfs.

hdfs dfs -put [Локальный путь к банке] hdfs://localhost:9000/home/user/hadoop-2.6.0/share/hadoop/mapreduce/

ОШИБКА [основная]: exec.Task (SessionState.java:printError(833)) — сбой отправки задания с исключением 'java.io.FileNotFoundException (файл не существует: hdfs://localhost:9000/home/user/hadoop- 2.6.0/share/hadoop/mapreduce/hadoop-mapreduce-client-core-2.6.0.jar)' java.io.FileNotFoundException: Файл не существует: hdfs://localhost:9000/home/user/hadoop- 2.6.0/share/hadoop/mapreduce/hadoop-mapreduce-client-core-2.6.0.jar по адресу org.apache.hadoop.hdfs.DistributedFileSystem$18.doCall(DistributedFileSystem.java:1122) по адресу org.apache.hadoop. hdfs.DistributedFileSystem$18.doCall(DistributedFileSystem.java:1114) в org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81) в org.apache.hadoop.hdfs.DistributedFileSystem.getFileStatus(DistributedFileSystem.java:1114) ) в org.apache.hadoop.mapreduce.filecache.ClientDistributedCacheManager.getFileStatus(ClientDistributedCacheManager.java:288) в org.apache.hadoop.mapreduce.filecache.ClientDistributedCacheManag er.getFileStatus(ClientDistributedCacheManager.java:224) в org.apache.hadoop.mapreduce.filecache.ClientDistributedCacheManager.determineTimestamps(ClientDistributedCacheManager.java:93) в org.apache.hadoop.mapreduce.filecache.ClientDistributedCacheManager.determineTimestampsAndCacheVisibilities(ClientDistributedCacheManager.java: 57) на org.apache.hadoop.mapreduce.JobSubmitter.copyAndConfigureFiles(JobSubmitter.java:269) на org.apache.hadoop.mapreduce.JobSubmitter.copyAndConfigureFiles(JobSubmitter.java:390) на org.apache.hadoop.mapreduce.JobSubmitter .submitJobInternal(JobSubmitter.java:483) в org.apache.hadoop.mapreduce.Job$10.run(Job.java:1296) в org.apache.hadoop.mapreduce.Job$10.run(Job.java:1293) в java.security.AccessController.doPrivileged(собственный метод) в javax.security.auth.Subject.doAs(Subject.java:415) в org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1628) в org. apache.hadoop.mapreduce.Job.sub mit(Job.java:1293) в 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:1628) в 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:429) в org.apache.hadoop.hive.ql.exec.mr. MapRedTask.execute(MapRedTask.java:137) в org.apache.hadoop.hive.ql.exec.Task.executeTask(Task.java:160) в org.apache.hadoop.hive.ql.exec.TaskRunner.runSequential( TaskRunner.java:85) в org.apache.hadoop.hive.ql.Driver.launchTask(Driver.java:1604) в org.apache.hadoop.hive.ql.Driver.execute(Driver.java:1364) в org. .apache.hadoop.hive.ql.Driver.runInternal(Driver.java:1177) в org.apache.hadoop.hive.ql.Driver.run(Driver.java:1004) в org.apache.hadoop.hive.ql .Driver.run(Driver.java:994) в org.apache.hadoop.hive.cli.CliDriver.processLocalCmd(CliDriver.java:201) в org.apache.hadoop.hive.cli.CliDriver.processCmd(CliDriver.java :153) в org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:364) в org.apache.hadoop.hive.cli.CliDriver.executeDriver(CliDriver.java:712) в o rg.apache.hadoop.hive.cli.CliDriver.run(CliDriver.java:631) в org.apache.hadoop.hive.cli.CliDriver.main(CliDriver.java:570) в 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.run(RunJar.java:221) в org.apache.hadoop.util.RunJar.main(RunJar.java:136)

person Partha Kaushik    schedule 24.04.2015