我正在尝试将数据插入分区表中。我正在使用 PrestoSqlOperator (airflow DAG) 来运行 presto/trino SQL 查询。
我可以使用命令将数据插入表中
插入表格......
但是如果我尝试使用下面的命令
插入覆盖表.....
抛出错误。
请帮我说出正确的说法。
我也尝试过删除分区,但没有取得太大成功。
Trino v 419 中添加了插入覆盖功能
INSERT OVERWRITE hive.test2.insert_test SELECT * FROM tpch.sf1.customer;
之前的实现是:
SET SESSION hive.insert_existing_partitions_behavior='OVERWRITE';
INSERT INTO hive.test2.insert_test SELECT * FROM tpch.sf1.customer;
查看更多详情https://github.com/trinodb/trino/issues/11602 https://github.com/trinodb/trino/issues?page=2&q=+insert+overwrite 和https://github.com/trinodb/trino/issues?page=2&q=+insert+overwrite