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 ce52353 commit 422ff4aCopy full SHA for 422ff4a
sql/core/src/main/scala/org/apache/spark/sql/sources/DataSourceStrategy.scala
@@ -147,7 +147,8 @@ private[sql] object DataSourceStrategy extends Strategy {
147
mergePartitionValues(output, partitionValues, scan)
148
}
149
150
- val unionedRows = perPartitionRows.reduceOption(_ ++ _).getOrElse(relation.sqlContext.emptyResult)
+ val unionedRows =
151
+ perPartitionRows.reduceOption(_ ++ _).getOrElse(relation.sqlContext.emptyResult)
152
createPhysicalRDD(logicalRelation.relation, output, unionedRows)
153
154
0 commit comments