在 org.apache.spark.sql.execution.datasources.orc.OrcColumnVector.getDecimal(OrcColumnVector.java:158)

问题描述

我试图从 HDFS 路径中读取数据,该路径是销售日期的一个分区,然后仅选择一个特定的列 spark 作业失败,该作业类型为小数 (32,20)(可空 = 真)。当我排除此列并选择其他列时,它工作正常。

点击 org.apache.spark.sql.execution.datasources.orc.OrcColumnVector.getDecimal(OrcColumnVector.java:158)

我采用的替代方法:我将一个数据样本放入另一个 HDFS 路径并查询它是否工作正常

我们可以在哪些情况下解决上述问题

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)