You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Spark 3.2.1中使用unionByName合并异列DataFrame报错求助

解决Spark Scala中unionByName的allowMissingColumns参数报错问题

你的报错原因很明确:Scala语言里的布尔值常量是小写的true,而你使用了Python风格的大写True,这属于基础语法错误,和Spark版本是否支持allowMissingColumns参数无关。

修正后的代码如下:

import spark.implicits._
val data = Seq(("1","[unassigned]"))
val DefaultResponseDF = data.toDF("try_number","assessment_item_response_xid") 

val data2 = Seq(("2"))
val DefaultResponseDF2 = data2.toDF("try_number") 
DefaultResponseDF.unionByName(DefaultResponseDF2, allowMissingColumns=true).show()

运行这段代码后,Spark会自动为缺失的列填充null值,顺利完成两个DataFrame的合并操作。

内容的提问来源于stack exchange,提问作者PriyalChaudhari

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.08.22 18:30:57