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 66e33fc commit 37c1c43Copy full SHA for 37c1c43
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala
@@ -153,9 +153,8 @@ case class InsertIntoHiveTable(
153
if (dynamicPartNum == 0) {
154
writer.setup(context.stageId, context.partitionId, attemptNumber)
155
writer.open()
156
- } else {
157
-
158
}
+
159
var count = 0
160
// writer for Dynamic Partition
161
var writer2: SparkHiveHadoopWriter = null
@@ -221,6 +220,7 @@ case class InsertIntoHiveTable(
221
220
.map { case (c, v) => s"/$c=${handleNull(v, defaultPartName)}" }
222
.mkString
223
224
/*
225
* if rowVal is null or "",will return HiveConf.get(hive.exec.default.partition.name) with default
226
* */
0 commit comments