解决问题spark读取mysql数据到hive断开连接

解决问题spark读取mysql数据到hive断开连接

解决问题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")