Merge 9f752b7 into 04b5256

apache · Dec 27, 2018 · abbed02 · abbed02
2 parents 04b5256 + 9f752b7
commit abbed02
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 1 deletion.
diff --git a/...arbondata/spark/testsuite/standardpartition/StandardPartitionTableOverwriteTestCase.scala b/...arbondata/spark/testsuite/standardpartition/StandardPartitionTableOverwriteTestCase.scala
@@ -296,6 +296,21 @@ class StandardPartitionTableOverwriteTestCase extends QueryTest with BeforeAndAf
     assert(sql("select * from partitionLoadTable").collect().length == 2)
   }
 
+  test("Test overwrite static partition when partition column is in capital letters ") {
+    sql(
+      """
+        | CREATE TABLE weather8 (type String)
+        | PARTITIONED BY (year int, month int, day int)
+        | STORED BY 'org.apache.carbondata.format'
+      """.stripMargin)
+
+    sql("insert into weather8 partition(year=2014, month=05, day=25) select 'rainy'")
+    sql("insert into weather8 partition(year=2014, month=04, day=23) select 'cloudy'")
+    sql("insert overwrite table weather8 partition(YEAR=2014, MONTH=5, DAY=25) select 'sunny'")
+    checkExistence(sql("select * from weather8"), true, "sunny")
+    checkAnswer(sql("select count(*) from weather8"), Seq(Row(3)))
+  }
+
   override def afterAll = {
     dropTable
   }
@@ -309,6 +324,7 @@ class StandardPartitionTableOverwriteTestCase extends QueryTest with BeforeAndAf
     sql("drop table if exists partitionallcompaction")
     sql("drop table if exists weather6")
     sql("drop table if exists weather7")
+    sql("drop table if exists weather8")
     sql("drop table if exists uniqdata_hive_static")
     sql("drop table if exists uniqdata_hive_dynamic")
     sql("drop table if exists uniqdata_string_static")

diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/execution/strategy/DDLStrategy.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/execution/strategy/DDLStrategy.scala
@@ -103,7 +103,10 @@ class DDLStrategy(sparkSession: SparkSession) extends SparkStrategy {
         }
       case InsertIntoCarbonTable(relation: CarbonDatasourceHadoopRelation,
       partition, child: LogicalPlan, overwrite, _) =>
-        ExecutedCommandExec(CarbonInsertIntoCommand(relation, child, overwrite, partition)) :: Nil
+        ExecutedCommandExec(CarbonInsertIntoCommand(relation, child, overwrite,
+          partition.map {
+            case (key, value) =>
+              (key.toLowerCase, value) })) :: Nil
       case createDb@CreateDatabaseCommand(dbName, ifNotExists, _, _, _) =>
         val dbLocation = try {
           CarbonEnv.getDatabaseLocation(dbName, sparkSession)