use HiveConf.DEFAULTPARTITIONNAME to replace hive.exec.default.partit…

…ion.name
manishamde · Sep 17, 2014 · 2201c75 · 2201c75
1 parent b47c9bf
commit 2201c75
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala
@@ -301,8 +301,8 @@ case class InsertIntoHiveTable(
       val fieldOIs = standardOI.getAllStructFieldRefs.map(_.getFieldObjectInspector).toArray
       val outputData = new Array[Any](fieldOIs.length)
       val defaultPartName = jobConfSer.value.get(
-        "hive.exec.default.partition.name ", "__HIVE_DEFAULT_PARTITION__")
-
+        HiveConf.ConfVars.DEFAULTPARTITIONNAME.varname, HiveConf.ConfVars.DEFAULTPARTITIONNAME.defaultVal)
+      
       val partitionColumns = fileSinkConf.getTableInfo.
         getProperties.getProperty("partition_columns") // a String like "colname1/colname2"
       val partitionColumnNames = Option(partitionColumns).map(_.split("/")).orNull