[SQL] [MINOR] Skip unresolved expression for InConversion

Author: scwf <[email protected]> Closes apache#6145 from scwf/InConversion and squashes the following commits: 5c8ac6b [scwf] minir fix for InConversion
Debasish-Das-CK · May 17, 2015 · edf09ea · edf09ea
1 parent 1a7b9ce
commit edf09ea
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/HiveTypeCoercion.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/HiveTypeCoercion.scala
@@ -296,6 +296,9 @@ trait HiveTypeCoercion {
    */
   object InConversion extends Rule[LogicalPlan] {
     def apply(plan: LogicalPlan): LogicalPlan = plan transformAllExpressions {
+      // Skip nodes who's children have not been resolved yet.
+      case e if !e.childrenResolved => e 
+
       case i @ In(a, b) if b.exists(_.dataType != a.dataType) =>
         i.makeCopy(Array(a, b.map(Cast(_, a.dataType))))
     }