• 写入mysql太慢

jdbc添加rewriteBatchedStatements=true

• 减少 spark sql stage

spark.conf.get("spark.sql.shuffle.partitions")

ui 配置

https://spark.apache.org/docs/3.3.2/configuration.html#runtime-environment

spark.streaming.ui.retainedBatches