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 202dac1 commit ffd237aCopy full SHA for ffd237a
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/InsertIntoHiveTable.scala
@@ -258,5 +258,7 @@ case class InsertIntoHiveTable(
258
259
override def executeCollect(): Array[Row] = sideEffectResult.toArray
260
261
- protected override def doExecute(): RDD[Row] = sqlContext.sparkContext.parallelize(sideEffectResult, 1)
+ protected override def doExecute(): RDD[Row] = {
262
+ sqlContext.sparkContext.parallelize(sideEffectResult, 1)
263
+ }
264
}
0 commit comments