@@ -255,18 +255,6 @@ class HiveQuerySuite extends HiveComparisonTest {
255
255
|insert overwrite table src_lv2 SELECT key, D.* lateral view explode(array(key+3, key+4)) D as CX
256
256
""" .stripMargin)
257
257
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
-
270
258
createQueryTest(" lateral view5" ,
271
259
" FROM src SELECT explode(array(key+3, key+4))" )
272
260
@@ -534,6 +522,28 @@ class HiveQuerySuite extends HiveComparisonTest {
534
522
case class LogEntry (filename : String , message : String )
535
523
case class LogFile (name : String )
536
524
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
+
537
547
test(" SPARK-3414 regression: should store analyzed logical plan when registering a temp table" ) {
538
548
sparkContext.makeRDD(Seq .empty[LogEntry ]).registerTempTable(" rawLogs" )
539
549
sparkContext.makeRDD(Seq .empty[LogFile ]).registerTempTable(" logFiles" )
0 commit comments