【发布时间】:2014-12-24 20:27:11
【问题描述】:
我在工作中使用 HDP 2.1 沙盒。 jar 文件中列出的 hive 版本为:hive-exec-0.13.0.2.1.1.0-385.jar。
我在 HDFS 中创建了一个包含天气信息的目录。实际信息在具有以下 5 个字段的文本文件中(usafid:string,obsdate:string,winddir:int,windspeed:int,visibility:double), 例如。文件内容是:
- 725805 201301010853 70 8 10.0
- 725805 201301010953 350 6 10.0
- 725805 201301011053 20 11 10.0
- 725805 201301011153 20 8 10.0
我现在正在使用 SQL 命令覆盖一个 HIVE 表
CREATE DATABASE weather;
USE weather;
CREATE EXTERNAL TABLE IF NOT EXISTS wind(
usafid STRING,
obsdate STRING,
winddir INT,
windspeed INT,
visibility DOUBLE
)
ROW FORMAT DELIMITED
FIELDS TERMINATED BY '\t'
LINES TERMINATED BY '\n'
STORED AS TEXTFILE
LOCATION '/WEATHER/PROCESSED/WIND_RECORDS';
当我运行查询SELECT * from wind; 时,它运行良好。但是,如果我运行查询 SELECT * from wind WHERE wind = 3;,hive 会启动 MR 作业并失败并显示以下堆栈跟踪:
2014-10-29 00:10:58,975 ERROR [IPC Server handler 3 on 52990] org.apache.hadoop.mapred.TaskAttemptListenerImpl: Task: attempt_1414566304731_0001_m_000000_0 - exited : java.lang.RuntimeException: java.lang.ArrayIndexOutOfBoundsException: 0
at org.apache.hadoop.hive.ql.exec.Utilities.getBaseWork(Utilities.java:284)
at org.apache.hadoop.hive.ql.exec.Utilities.getMapWork(Utilities.java:250)
at org.apache.hadoop.hive.ql.io.HiveInputFormat.init(HiveInputFormat.java:256)
at org.apache.hadoop.hive.ql.io.HiveInputFormat.pushProjectionsAndFilters(HiveInputFormat.java:383)
at org.apache.hadoop.hive.ql.io.HiveInputFormat.pushProjectionsAndFilters(HiveInputFormat.java:376)
at org.apache.hadoop.hive.ql.io.CombineHiveInputFormat.getRecordReader(CombineHiveInputFormat.java:552)
at org.apache.hadoop.mapred.MapTask$TrackedRecordReader.<init>(MapTask.java:168)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:409)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
at org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:167)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:415)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1557)
at org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:162)
Caused by: java.lang.ArrayIndexOutOfBoundsException: 0
at java.beans.XMLDecoder.readObject(XMLDecoder.java:250)
at org.apache.hadoop.hive.ql.exec.Utilities.deserializeObject(Utilities.java:679)
at org.apache.hadoop.hive.ql.exec.Utilities.deserializePlan(Utilities.java:622)
at org.apache.hadoop.hive.ql.exec.Utilities.getBaseWork(Utilities.java:272)
我做了很多研究和挖掘,并且能够在解析“查询计划”期间跟踪错误。任何带有“WHERE”子句的查询都会失败。如果我使用该命令将执行引擎设置为 Tez,则查询运行良好。
set hive.execution.engine=tez;
不确定发生了什么以及为什么在hive.execution.engine=mr(我相信这是默认设置)时它会失败?
编辑:我设置了一个 3 节点集群并使用 Ambari 来安装和设置 HDP 2.1。我无法在 3 节点集群上重新创建问题。看起来该问题仅在独立 VM HDP 2.1 中表现出来。
【问题讨论】:
标签: hadoop hive hortonworks-data-platform