File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -292,7 +292,7 @@ object RewritePredicateSubquery extends Rule[LogicalPlan] with PredicateHelper {
292292 // +- LocalRelation [col1#28, col2#29]
293293 //
294294 // Note that the Aggregate node contains the IN-subquery and the left-hand
295- // side of the IN-subquery is an aggregate expression (sum(col2#28 )).
295+ // side of the IN-subquery is an aggregate expression (sum(col2#29 )).
296296 //
297297 // This handler transforms the above plan into the following:
298298 //
@@ -303,7 +303,7 @@ object RewritePredicateSubquery extends Rule[LogicalPlan] with PredicateHelper {
303303 //
304304 // The transformation pulled the IN-subquery up into a Project. The left-hand side of the
305305 // IN-subquery is now an attribute (sum(col2)#36L) that refers to the actual aggregation
306- // which is still performed in the Aggregate node (sum(col2#28 ) AS sum(col2)#36L). The Unary
306+ // which is still performed in the Aggregate node (sum(col2#29 ) AS sum(col2)#36L). The Unary
307307 // node handler will use that attribute in the join condition (rather than the aggregate
308308 // expression).
309309 //
You can’t perform that action at this time.
0 commit comments