如何在spark jdbc中处理不一致的提交

8wtpewkr  于 2021-05-19  发布在  Spark
关注(0)|答案(0)|浏览(292)

使用spark,我将数据从一个区域移动到另一个区域(postgres),进行一些转换。df.write.mode(savemode.append).option(“truncate”,true).jdbc()。如果任何一个执行器由于某些sqlexception而失败,是否有任何方法可以回滚在不同执行器中发生的所有数据写入?。我想避免不一致的承诺。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题