@@ -255,18 +255,6 @@ class HiveQuerySuite extends HiveComparisonTest {
255255 |insert overwrite table src_lv2 SELECT key, D.* lateral view explode(array(key+3, key+4)) D as CX
256256 """ .stripMargin)
257257
258- createQueryTest(" dynamic_partiton" ,
259- """
260- |drop table IF EXISTS dynamic_part_table;
261- |create table dynamic_part_table(intcol int) partitioned by (partcol1 int, partcol2 int);
262- |set hive.exec.dynamic.partition.mode=nonstrict;
263- |insert into table dynamic_part_table partition(partcol1, partcol2) select 1, 1, 1 from src where key=150;
264- |insert into table dynamic_part_table partition(partcol1, partcol2) select 1, NULL, 1 from src where key=150;
265- |insert into table dynamic_part_table partition(partcol1, partcol2) select 1, 1, NULL from src where key=150;
266- |insert into table dynamic_part_table partition(partcol1, partcol2) select 1, NULL, NULL from src where key=150;
267- |drop table IF EXISTS dynamic_part_table;
268- """ .stripMargin)
269-
270258 createQueryTest(" lateral view5" ,
271259 " FROM src SELECT explode(array(key+3, key+4))" )
272260
@@ -534,6 +522,28 @@ class HiveQuerySuite extends HiveComparisonTest {
534522 case class LogEntry (filename : String , message : String )
535523 case class LogFile (name : String )
536524
525+ createQueryTest(" dynamic_partition" ,
526+ """
527+ |DROP TABLE IF EXISTS dynamic_part_table;
528+ |CREATE TABLE dynamic_part_table(intcol INT) PARTITIONED BY (partcol1 INT, partcol2 INT);
529+ |
530+ |SET hive.exec.dynamic.partition.mode=nonstrict;
531+ |
532+ |INSERT INTO TABLE dynamic_part_table PARTITION(partcol1, partcol2)
533+ |SELECT 1, 1, 1 FROM src WHERE key=150;
534+ |
535+ |INSERT INTO TABLE dynamic_part_table PARTITION(partcol1, partcol2)
536+ |SELECT 1, NULL, 1 FROM src WHERE key=150;
537+ |
538+ |INSERT INTO TABLE dynamic_part_table PARTITION(partcol1, partcol2)
539+ |SELECT 1, 1, NULL FROM src WHERE key=150;
540+ |
541+ |INSERT INTO TABLe dynamic_part_table PARTITION(partcol1, partcol2)
542+ |SELECT 1, NULL, NULL FROM src WHERE key=150;
543+ |
544+ |DROP TABLE IF EXISTS dynamic_part_table;
545+ """ .stripMargin)
546+
537547 test(" SPARK-3414 regression: should store analyzed logical plan when registering a temp table" ) {
538548 sparkContext.makeRDD(Seq .empty[LogEntry ]).registerTempTable(" rawLogs" )
539549 sparkContext.makeRDD(Seq .empty[LogFile ]).registerTempTable(" logFiles" )
0 commit comments