File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed
catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans
core/src/main/scala/org/apache/spark/sql/execution Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -263,7 +263,9 @@ abstract class QueryPlan[PlanType <: QueryPlan[PlanType]] extends TreeNode[PlanT
263263 * All the subqueries of current plan.
264264 */
265265 def subqueries : Seq [PlanType ] = {
266- expressions.flatMap(_.collect {case e : SubqueryExpression => e.plan.asInstanceOf [PlanType ]})
266+ expressions.flatMap(_.collect {
267+ case e : SubqueryExpression => e
268+ }).distinct.map(_.plan.asInstanceOf [PlanType ])
267269 }
268270
269271 override protected def innerChildren : Seq [QueryPlan [_]] = subqueries
Original file line number Diff line number Diff line change @@ -94,7 +94,7 @@ case class ReusedScalarSubquery(
9494 child : ScalarSubquery ) extends UnaryExpression {
9595
9696 override def dataType : DataType = child.dataType
97- override def toString : String = s " ReusedSubquery# ${exprId.id} ( $child) "
97+ override def toString : String = s " ReusedSubquery# ${exprId.id}( $child) "
9898
9999 override def doGenCode (ctx : CodegenContext , ev : ExprCode ): ExprCode =
100100 defineCodeGen(ctx, ev, c => c)
You can’t perform that action at this time.
0 commit comments