Github user dbtsai commented on a diff in the pull request:
https://github.com/apache/spark/pull/21416#discussion_r190799418
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/subquery.scala
---
@@ -149,7 +149,7 @@ object RewritePredicateSubquery extends
Rule[LogicalPlan] with PredicateHelper {
newPlan = dedupJoin(
Join(newPlan, sub, ExistenceJoin(exists),
conditions.reduceLeftOption(And)))
exists
- case In(value, Seq(ListQuery(sub, conditions, _, _))) =>
+ case EqualTo(value, ListQuery(sub, conditions, _, _)) =>
--- End diff --
@dongjoon-hyun this should fix the test. I'll add one test for this.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
