Fix again.

apache · Jul 7, 2016 · eead3db · eead3db
1 parent f068e4b
commit eead3db
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
@@ -834,7 +834,7 @@ case class OptimizeIn(conf: CatalystConf) extends Rule[LogicalPlan] {
           val hSet = newList.map(e => e.eval(EmptyRow))
           InSet(v, HashSet() ++ hSet)
         } else if (newList.size < list.size) {
-          In(v, newList)
+          expr.copy(list = newList)
         } else { // newList.length == list.length
           expr
         }