We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2201c75 commit 5033928Copy full SHA for 5033928
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala
@@ -301,7 +301,8 @@ case class InsertIntoHiveTable(
301
val fieldOIs = standardOI.getAllStructFieldRefs.map(_.getFieldObjectInspector).toArray
302
val outputData = new Array[Any](fieldOIs.length)
303
val defaultPartName = jobConfSer.value.get(
304
- HiveConf.ConfVars.DEFAULTPARTITIONNAME.varname, HiveConf.ConfVars.DEFAULTPARTITIONNAME.defaultVal)
+ HiveConf.ConfVars.DEFAULTPARTITIONNAME.varname,
305
+ HiveConf.ConfVars.DEFAULTPARTITIONNAME.defaultVal)
306
307
val partitionColumns = fileSinkConf.getTableInfo.
308
getProperties.getProperty("partition_columns") // a String like "colname1/colname2"
0 commit comments