apache-spark - 在 org.apache.spark.sql.execution.datasources.orc.OrcColumnVector.getDecimal(OrcColumnVector.java:158)
问题描述
我正在尝试从 HDFS 路径中读取,该路径是销售日期的一个分区,然后仅选择一个特定的列 spark 作业失败,其类型为小数(32,20)(可为空 = true)。当我排除此列并选择其他列时,它工作正常。
访问 org.apache.spark.sql.execution.datasources.orc.OrcColumnVector.getDecimal(OrcColumnVector.java:158)
我采用的替代方法:我将数据样本放入另一个 HDFS 路径并查询它工作正常
什么情况下我们可以解决上述问题
解决方案
推荐阅读
- android - 每当我打开我的 android studio 并单击运行时,它都不会运行应用程序
- php - 如何在php codeigniter中将数组对象数据打印到数组数据中
- javascript - 如何将 JSON 数据显示到动态输入文本字段中?
- ios - 操作无法完成 com.facebook.sdk 错误 3 - IOS-react-native-FBSDK
- scala - 在 Spark 流 Scala 中将 RDD 写入弹性搜索需要时间
- python - 为 Flask heroku 应用程序部署设置 Procfile 时遇到问题
- python-3.x - USB HID 代码之谜
- excel - 重新排列方程
- node.js - 无法在 nodejs 打字稿中使用生成器
- visual-studio - 缺少共享的 Visual Studio 项目模板