fix review findings 2

peter-toth · peter-toth · commit d0c57c8994da · 2019-07-03T11:09:04.000+02:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
@@ -229,7 +229,7 @@ class Analyzer(
     private def substituteCTE(
         plan: LogicalPlan,
         cteName: String,
-        ctePlan: LogicalPlan): LogicalPlan =
+        ctePlan: LogicalPlan): LogicalPlan = {
       plan resolveOperatorsUp {
         case UnresolvedRelation(Seq(table)) if resolver(cteName, table) =>
           ctePlan
@@ -240,6 +240,7 @@ class Analyzer(
               e.withNewPlan(substituteCTE(e.plan, cteName, ctePlan))
           }
       }
+    }
   }
 
   /**

Original file line number	Diff line number	Diff line change
`@@ -229,7 +229,7 @@ class Analyzer(`
`229`	`229`	`private def substituteCTE(`
`230`	`230`	`plan: LogicalPlan,`
`231`	`231`	`cteName: String,`
`232`		`- ctePlan: LogicalPlan): LogicalPlan =`
	`232`	`+ ctePlan: LogicalPlan): LogicalPlan = {`
`233`	`233`	`plan resolveOperatorsUp {`
`234`	`234`	`case UnresolvedRelation(Seq(table)) if resolver(cteName, table) =>`
`235`	`235`	`ctePlan`
`@@ -240,6 +240,7 @@ class Analyzer(`
`240`	`240`	`e.withNewPlan(substituteCTE(e.plan, cteName, ctePlan))`
`241`	`241`	`}`
`242`	`242`	`}`
	`243`	`+ }`
`243`	`244`	`}`
`244`	`245`
`245`	`246`	`/**`