pyspark Delta Lake替换Where SQL子句错误

slsn1g29  于 2023-03-01  发布在  Spark
关注(0)|答案(1)|浏览(234)

请帮助,使用Delta“replace where”SQL(非Python)时出现此错误:

ParseException: 
mismatched input 'replace' expecting {'(', 'DESC', 'DESCRIBE', 'FROM', 'MAP', 'REDUCE', 'SELECT', 'TABLE', 'VALUES', 'WITH'}(line 1, pos 72)

== SQL ==
insert into table delta.`/path-to-table/` replace where replace_key in ('a', 'b') select * from vwt_df

我正在使用这个指南(sql版本):https://docs.databricks.com/delta/selective-overwrite.html#language-sql
我正在尝试执行选择性覆盖。

qyswt5oh

qyswt5oh1#

技术答案-问题是因为使用了旧版本的数据库运行时。根据文档,对于SQL支持,需要DBR 12.0+。

相关问题