aused by: java.util.concurrent.ExecutionException: org.apache.spark.util.SparkFatalException
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:206)
at org.apache.spark.sql.execution.exchange.BroadcastExchangeExec$$anonfun$doExecuteBroadcast$2.apply$mcVI$sp(BroadcastExchangeExec.scala:152)
at org.apache.spark.sql.execution.exchange.BroadcastExchangeExec$$anonfun$doExecuteBroadcast$2.apply(BroadcastExchangeExec.scala:1502
2、解决方案
方案1） 设置一下spark.sql.autoBroadcastJoinThreshold=-1
方案2） 调低 spark.sql.autoBroadcastJoinThreshold=10485760