可能是toDF
之前的数据是这样的:
inputDF.map(row => {
if (sometimeTrue) {
(1,2,3)
} else {
(1,2)
}
}).toDF("1", "2", "3")
结果长度没对齐
Spark 报错 no Java class corresponding to Product with Serializable found
阅读 130
2022-11-26
可能是toDF
之前的数据是这样的:
inputDF.map(row => {
if (sometimeTrue) {
(1,2,3)
} else {
(1,2)
}
}).toDF("1", "2", "3")
结果长度没对齐
相关推荐
精彩评论(0)