File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -301,8 +301,8 @@ case class InsertIntoHiveTable(
301301 val fieldOIs = standardOI.getAllStructFieldRefs.map(_.getFieldObjectInspector).toArray
302302 val outputData = new Array [Any ](fieldOIs.length)
303303 val defaultPartName = jobConfSer.value.get(
304- " hive.exec.default.partition.name " , " __HIVE_DEFAULT_PARTITION__ " )
305-
304+ HiveConf . ConfVars . DEFAULTPARTITIONNAME .varname, HiveConf . ConfVars . DEFAULTPARTITIONNAME .defaultVal )
305+
306306 val partitionColumns = fileSinkConf.getTableInfo.
307307 getProperties.getProperty(" partition_columns" ) // a String like "colname1/colname2"
308308 val partitionColumnNames = Option (partitionColumns).map(_.split(" /" )).orNull
You can’t perform that action at this time.
0 commit comments