当尝试在一些测试中运行相当简单的插入语句时，我收到以下错误：
E pyspark.sql.utils.AnalysisException: unresolved operator 'InsertIntoStatement LogicalRDD [name#0, run_timestamp#1], false, false, false;
E 'InsertIntoStatement LogicalRDD [name#0, run_timestamp#1], false, false, false
E +- LocalRelation [col1#6, col2#7]
这是什么意思？我已经在 python 笔记本中检查了我的 SQL，它工作得很好。
self.spark.sql(f'''
INSERT INTO migrations
VALUES ("{job_name}", now())
'''
我试过放置一个breakpoint()并做一个describe表名上显示它存在。
在我们的例子中，这是因为migrations实际上是一个view而不是一个table因此插入显然失败了（如果错误消息更好的话！）。
我们的测试装置设置不正确（createOrReplaceTempView正在使用）。
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
