File tree Expand file tree Collapse file tree 3 files changed +2
-2
lines changed
core/src/main/scala/org/apache/spark/sql
main/scala/org/apache/spark/sql/hive
test/scala/org/apache/spark/sql/hive/execution Expand file tree Collapse file tree 3 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -282,7 +282,7 @@ class SQLContext(@transient val sparkContext: SparkContext)
282282 logical match {
283283 case SetCommand (key, value) =>
284284 sqlConf.set(key, value)
285- emptyResult // TODO: should this return something else?
285+ emptyResult // TODO: should this return something else? Single row consisting of one 0?
286286 case _ => executedPlan.execute()
287287 }
288288 }
Original file line number Diff line number Diff line change @@ -258,7 +258,6 @@ class HiveContext(sc: SparkContext) extends SQLContext(sc) {
258258
259259 analyzed match {
260260 case SetCommand (key, value) =>
261- logger.debug(" inside Hive's toRdd -- matched SetCommand" )
262261 // Record the set command inside SQLConf, as well as have Hive execute it.
263262 sqlConf.set(key, value)
264263 processCmd(s " set $key= $value" )
Original file line number Diff line number Diff line change @@ -138,6 +138,7 @@ abstract class HiveComparisonTest
138138
139139 val orderedAnswer = hiveQuery.logical match {
140140 // Clean out non-deterministic time schema info.
141+ case _ : SetCommand => Seq (" 0" )
141142 case _ : NativeCommand => answer.filterNot(nonDeterministicLine).filterNot(_ == " " )
142143 case _ : ExplainCommand => answer
143144 case plan => if (isSorted(plan)) answer else answer.sorted
You can’t perform that action at this time.
0 commit comments