@@ -271,18 +271,6 @@ class HiveQuerySuite extends HiveComparisonTest {
271271 |insert overwrite table src_lv2 SELECT key, D.* lateral view explode(array(key+3, key+4)) D as CX
272272 """ .stripMargin)
273273
274- createQueryTest(" dynamic_partiton" ,
275- """
276- |drop table IF EXISTS dynamic_part_table;
277- |create table dynamic_part_table(intcol int) partitioned by (partcol1 int, partcol2 int);
278- |set hive.exec.dynamic.partition.mode=nonstrict;
279- |insert into table dynamic_part_table partition(partcol1, partcol2) select 1, 1, 1 from src where key=150;
280- |insert into table dynamic_part_table partition(partcol1, partcol2) select 1, NULL, 1 from src where key=150;
281- |insert into table dynamic_part_table partition(partcol1, partcol2) select 1, 1, NULL from src where key=150;
282- |insert into table dynamic_part_table partition(partcol1, partcol2) select 1, NULL, NULL from src where key=150;
283- |drop table IF EXISTS dynamic_part_table;
284- """ .stripMargin)
285-
286274 createQueryTest(" lateral view5" ,
287275 " FROM src SELECT explode(array(key+3, key+4))" )
288276
@@ -580,6 +568,28 @@ class HiveQuerySuite extends HiveComparisonTest {
580568 case class LogEntry (filename : String , message : String )
581569 case class LogFile (name : String )
582570
571+ createQueryTest(" dynamic_partition" ,
572+ """
573+ |DROP TABLE IF EXISTS dynamic_part_table;
574+ |CREATE TABLE dynamic_part_table(intcol INT) PARTITIONED BY (partcol1 INT, partcol2 INT);
575+ |
576+ |SET hive.exec.dynamic.partition.mode=nonstrict;
577+ |
578+ |INSERT INTO TABLE dynamic_part_table PARTITION(partcol1, partcol2)
579+ |SELECT 1, 1, 1 FROM src WHERE key=150;
580+ |
581+ |INSERT INTO TABLE dynamic_part_table PARTITION(partcol1, partcol2)
582+ |SELECT 1, NULL, 1 FROM src WHERE key=150;
583+ |
584+ |INSERT INTO TABLE dynamic_part_table PARTITION(partcol1, partcol2)
585+ |SELECT 1, 1, NULL FROM src WHERE key=150;
586+ |
587+ |INSERT INTO TABLe dynamic_part_table PARTITION(partcol1, partcol2)
588+ |SELECT 1, NULL, NULL FROM src WHERE key=150;
589+ |
590+ |DROP TABLE IF EXISTS dynamic_part_table;
591+ """ .stripMargin)
592+
583593 test(" SPARK-3414 regression: should store analyzed logical plan when registering a temp table" ) {
584594 sparkContext.makeRDD(Seq .empty[LogEntry ]).registerTempTable(" rawLogs" )
585595 sparkContext.makeRDD(Seq .empty[LogFile ]).registerTempTable(" logFiles" )
0 commit comments