Skip to content

Commit 2ead378

Browse files
committed
follow comment
1 parent 25f31dc commit 2ead378

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/CheckAnalysis.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -605,7 +605,7 @@ trait CheckAnalysis extends PredicateHelper {
605605
case _: Filter | _: SupportsSubquery | _: Join => // Ok
606606
case _ =>
607607
failAnalysis(s"IN/EXISTS predicate sub-queries can only be used in" +
608-
s" Filter/SupportsSubquery/Join and a few commands: $plan")
608+
s" Filter/Join and a few commands: $plan")
609609
}
610610
}
611611

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/ResolveSubquerySuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ import org.apache.spark.sql.AnalysisException
2121
import org.apache.spark.sql.catalyst.dsl.expressions._
2222
import org.apache.spark.sql.catalyst.expressions.{InSubquery, ListQuery}
2323
import org.apache.spark.sql.catalyst.plans.Inner
24-
import org.apache.spark.sql.catalyst.plans.logical.{Filter, Join, LocalRelation, Project}
24+
import org.apache.spark.sql.catalyst.plans.logical._
2525

2626
/**
2727
* Unit tests for [[ResolveSubquery]].
@@ -50,7 +50,7 @@ class ResolveSubquerySuite extends AnalysisTest {
5050
t2,
5151
Inner,
5252
Some(InSubquery(Seq(a), ListQuery(Project(Seq(UnresolvedAttribute("c")), t3)))),
53-
null)
53+
JoinHint.NONE)
5454
assertAnalysisSuccess(expr)
5555
}
5656
}

0 commit comments

Comments
 (0)