Skip to content

Commit

Permalink
Revert "Undo part of a SparkPlanTest change in #7162 that broke my te…
Browse files Browse the repository at this point in the history
…st."

This reverts commit 7c3c864.
  • Loading branch information
JoshRosen committed Jul 7, 2015
1 parent 7c3c864 commit 0a79d39
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -301,9 +301,7 @@ object SparkPlanTest {
val resolvedPlan = TestSQLContext.prepareForExecution.execute(
outputPlan transform {
case plan: SparkPlan =>
val inputMap = plan.children.flatMap(_.output).zipWithIndex.map { case (a, i) =>
(a.name, BoundReference(i, a.dataType, a.nullable))
}.toMap
val inputMap = plan.children.flatMap(_.output).map(a => (a.name, a)).toMap
plan.transformExpressions {
case UnresolvedAttribute(Seq(u)) =>
inputMap.getOrElse(u,
Expand Down

0 comments on commit 0a79d39

Please sign in to comment.