Skip to content

Commit 86f28d5

Browse files
committed
use filterNot(SubqueryExpression.hasSubquery)
1 parent c34f030 commit 86f28d5

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/OptimizeMetadataOnlyQuery.scala

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -117,11 +117,7 @@ case class OptimizeMetadataOnlyQuery(catalog: SessionCatalog) extends Rule[Logic
117117
case a: AttributeReference =>
118118
a.withName(relation.output.find(_.semanticEquals(a)).get.name)
119119
}
120-
}
121-
122-
if (normalizedFilters.exists(_.find(_.isInstanceOf[Unevaluable]).isDefined)) {
123-
return child
124-
}
120+
}.filterNot(SubqueryExpression.hasSubquery)
125121

126122
child transform {
127123
case plan if plan eq relation =>

0 commit comments

Comments
 (0)