问题描述
在我的火花工作中,我试图覆盖结构化流的每个微批处理中的一个表
batchDF.write.mode(SaveMode.Overwrite).saveAsTable("mytable")
它产生了以下错误。
Can not create the managed table('`mytable`'). The associated location('file:/home/ec2-user/environment/spark/spark-local/spark-warehouse/mytable') already exists.;
我在Spark 2.xx中知道,解决此问题的方法是添加以下选项。
spark.conf.set("spark.sql.legacy.allowCreatingManagedTableusingNonemptyLocation","true")
在spark 2.xx中效果很好。但是,此选项已在Spark 3.0.0中删除。那么,我们应该如何在Spark 3.0.0中解决此问题?
谢谢!
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)