因为使用了笛卡尔积，但是在Spark2.x中是笛卡尔积操作是默认关闭，如果需要开启，则添加如下配置
val sparkSession = SparkSession.builder().master("local[*]").appName("wula")
.config("spark.sql.crossJoin.enabled","true").getOrCreate()记录一次Spark - org.apache.spark.sql.AnalysisException异常 2020.04.16
kamisamak
这个人很懒，什么都没留下
文章评论