Skip to content

Commit 8ad173c

Browse files
baishuoliancheng
authored andcommitted
Update InsertIntoHiveTable.scala
1 parent 051ba91 commit 8ad173c

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -270,7 +270,7 @@ case class InsertIntoHiveTable(
270270
}
271271
}
272272

273-
if (dynamicPartNum>0) {
273+
if (dynamicPartNum > 0) {
274274
if (outputClass == null) {
275275
throw new SparkException("Output value class not set")
276276
}
@@ -343,7 +343,6 @@ case class InsertIntoHiveTable(
343343
sc.hiveconf.getBoolean("hive.exec.compress.output", false))
344344
}
345345

346-
// TODO: Handle dynamic partitioning.
347346
val outputPath = FileOutputFormat.getOutputPath(jobConf)
348347
// Have to construct the format of dbname.tablename.
349348
val qualifiedTableName = s"${table.databaseName}.${table.tableName}"
@@ -359,7 +358,7 @@ case class InsertIntoHiveTable(
359358
val inheritTableSpecs = true
360359
// TODO: Correctly set isSkewedStoreAsSubdir.
361360
val isSkewedStoreAsSubdir = false
362-
if (dynamicPartNum>0) {
361+
if (dynamicPartNum > 0) {
363362
db.loadDynamicPartitions(
364363
outputPath,
365364
qualifiedTableName,

0 commit comments

Comments
 (0)