We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8c6060a commit 9a9d9d1Copy full SHA for 9a9d9d1
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/finishAnalysis.scala
@@ -56,7 +56,7 @@ object ReplaceExpressions extends Rule[LogicalPlan] {
56
* Rewrite non correlated exists subquery to use ScalarSubquery
57
* WHERE EXISTS (SELECT A FROM TABLE B WHERE COL1 > 10)
58
* will be rewrite to
59
- * WHERE (SELECT 1 FROM (SELECT A FROM TABLE B WHERE COL1 > 1) LIMIT 1) IS NOT NULL
+ * WHERE (SELECT 1 FROM (SELECT A FROM TABLE B WHERE COL1 > 10) LIMIT 1) IS NOT NULL
60
*/
61
object RewriteNonCorrelatedExists extends Rule[LogicalPlan] {
62
override def apply(plan: LogicalPlan): LogicalPlan = plan transformAllExpressions {
0 commit comments