不匹配的输入“覆盖”。期待：'INTO'

Question

我有一个带有架构的配置单元表

CREATE TABLE `temp_table`(
  `gpid` string
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
STORED AS TEXTFILE
LOCATION
  'wasbs://test@test.blob.core.windows.net/warehouse/test_data';

我正在使用气流 2 向其中添加数据。每次作业运行时我都需要覆盖数据，所以我尝试使用

INSERT OVERWRITE TABLE default.temp_table
select id from sometable

但我遇到了问题

trino.exceptions.TrinoUserError: TrinoUserError(type=USER_ERROR, name=SYNTAX_ERROR, message="line 1:8: mismatched input 'OVERWRITE'. Expecting: 'INTO'", query_id=20210817_140454_00001_rbuac)

Answer 1

来自Trino Documentation：

默认情况下，INSERT 查询不允许覆盖现有数据。您可以使用目录会话属性insert_existing_partitions_behavior 来允许覆盖。使用 Hive 连接器添加目录名称，例如 hdfs，并在运行插入查询之前在会话中设置属性：

SET SESSION hdfs.insert_existing_partitions_behavior = 'OVERWRITE';
INSERT INTO hdfs.schema.table ...

产生的行为等同于在 Hive 中使用 INSERT OVERWRITE。

当表存储在 S3、加密的 HDFS 或外部位置时，Trino 不支持插入覆盖操作。在这种情况下删除前插入。