Kaynağa Gözat

test(spark): 幂等测试加 hive 动态分区前置

补 set hive.exec.dynamic.partition=true / mode=nonstrict 两条;不设这两条
INSERT OVERWRITE PARTITION (dt) 全动态分区写法跑不起来。与本测试目标
spark.sql.sources.partitionOverwriteMode 无关,是底层执行必需条件。

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
tianyu.chu 1 gün önce
ebeveyn
işleme
af92767303

+ 5 - 0
tests/integration/spark/idempotence/partition_overwrite_default.sql

@@ -2,6 +2,11 @@
 -- 动态分区 INSERT OVERWRITE 的实际默认行为。
 -- 动态分区 INSERT OVERWRITE 的实际默认行为。
 -- 跑法见同目录 README.md。
 -- 跑法见同目录 README.md。
 
 
+-- Hive 动态分区前置(不设动态分区 INSERT 跑不起来;这两条与本测试目标
+-- spark.sql.sources.partitionOverwriteMode 无关,是底层执行必需条件)
+set hive.exec.dynamic.partition=true;
+set hive.exec.dynamic.partition.mode=nonstrict;
+
 CREATE DATABASE IF NOT EXISTS test;
 CREATE DATABASE IF NOT EXISTS test;
 
 
 DROP TABLE IF EXISTS test.idempotence_pom_default;
 DROP TABLE IF EXISTS test.idempotence_pom_default;