在 pyspark 中读取 Hive 托管表的 orc 文件答案

【问题标题】：Reading orc file of Hive managed tables in pyspark在 pyspark 中读取 Hive 托管表的 orc 文件
【发布时间】：2019-12-09 09:11:49
【问题描述】：

我正在尝试使用以下 pyspark 代码读取托管配置单元表的 orc 文件。

spark.read.format('orc').load('hive managed table path')

当我在获取的数据帧上执行打印模式时，如下所示

root
 |-- operation: integer (nullable = true)
 |-- originalTransaction: long (nullable = true)
 |-- bucket: integer (nullable = true)
 |-- rowId: long (nullable = true)
 |-- currentTransaction: long (nullable = true)
 |-- row: struct (nullable = true)
 |    |-- col1: float (nullable = true)
 |    |-- col2: integer (nullable = true)
 |-- partition_by_column: date (nullable = true)

现在我无法解析这些数据并对数据框进行任何操作。在应用 show() 之类的操作时，我收到一条错误消息

java.lang.IllegalArgumentException: Include vector the wrong length

有人遇到过同样的问题吗？如果是，请您建议如何解决它。

【问题讨论】：

select(df.row.col1) 这行得通吗？在那种情况下，我猜你可以用它来压平它。
我试过了，df.select("row.col1").show()，得到同样的错误

标签： apache-spark hadoop hive pyspark

【解决方案1】：

这是一个已知的issue。

您收到该错误是因为您尝试读取 Hive ACID 表，但 Spark 仍然不支持此操作。

也许您可以将 Hive 表导出为普通的 ORC 文件，然后使用 Spark 读取它们或尝试使用 Hive JDBC 等替代方法，如 here 所述

【讨论】：

【解决方案2】：

由于我不确定版本您可以尝试其他方式来加载 ORC 文件。

使用 SqlContext

val df = sqlContext.read.format("orc").load(orcfile)

或

val df= spark.read.option("inferSchema", true).orc("filepath")

或 SparkSql（推荐）

import spark.sql
sql("SELECT * FROM table_name").show()

【讨论】：

我已经尝试了以上两种方法，在执行操作时得到了指定的错误。
您使用的是哪个 spark 版本？
spark 版本 2.3.2.3.1.0.0-78
python 版本 2.7.5