Skip to content

Commit 79d14f1

Browse files
committed
Fix the build
1 parent 8bc7573 commit 79d14f1

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/expressions.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -224,7 +224,7 @@ object OptimizeIn extends Rule[LogicalPlan] {
224224
If(IsNotNull(v), FalseLiteral, Literal(null, BooleanType))
225225
case expr @ In(v, list) if expr.inSetConvertible =>
226226
val newList = ExpressionSet(list).toSeq
227-
if (newList.length == 1 && !newList.isInstanceOf[ListQuery]) {
227+
if (newList.length == 1 && !v.isInstanceOf[CreateNamedStructLike]) {
228228
EqualTo(v, newList.head)
229229
} else if (newList.length > SQLConf.get.optimizerInSetConversionThreshold) {
230230
val hSet = newList.map(e => e.eval(EmptyRow))

0 commit comments

Comments
 (0)