Update HiveQuerySuite.scala

YanTangZhai · Sep 17, 2014 · 0e18496 · 0e18496
1 parent 60f70aa
commit 0e18496
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala
@@ -255,6 +255,18 @@ class HiveQuerySuite extends HiveComparisonTest {
       |insert overwrite table src_lv2 SELECT key, D.* lateral view explode(array(key+3, key+4)) D as CX
     """.stripMargin)
 
+  createQueryTest("dynamice partiton",
+    """
+      |drop table IF EXISTS dynamic_part_table;
+      |create table dynamic_part_table(intcol int) partitioned by (partcol1 int, partcol2 int);
+      |set hive.exec.dynamic.partition.mode=nonstrict;
+      |insert  into table dynamic_part_table partition(partcol1, partcol2) select 1, 1, 1 from src where key=150;
+      |insert  into table dynamic_part_table partition(partcol1, partcol2) select 1, NULL, 1 from src where key=150;
+      |insert  into table dynamic_part_table partition(partcol1, partcol2) select 1, 1, NULL from src where key=150;
+      |insert  into table dynamic_part_table partition(partcol1, partcol2) select 1, NULL, NULL from src where key=150;
+      |drop table IF EXISTS dynamic_part_table;
+    """.stripMargin)
+
   createQueryTest("lateral view5",
     "FROM src SELECT explode(array(key+3, key+4))")