解决问题spark读取mysql数据到hive断开连接
之前的代码读取
loan_info_non_busi_snapshotDF.write.mode(SaveMode.Overwrite).saveAsTable("qjdods.loan_info_non_busi_snapshot")
改之后的代码读取
loan_info_non_busi_snapshotDF.coalesce(1).write.mode(SaveMode.Overwrite).saveAsTable("qjdods.loan_info_non_busi_snapshot")
