minor fix

adrian-wang · adrian-wang · commit 71e05ccae24c · 2015-04-21T23:28:46.000-07:00
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
@@ -286,7 +286,7 @@ trait HiveTypeCoercion {
    */
   object InConversion extends Rule[LogicalPlan] {
     def apply(plan: LogicalPlan): LogicalPlan = plan transformAllExpressions {
-      case i @ In(a, b) if b.exists(_.dataType != StringType) =>
+      case i @ In(a, b) if b.exists(_.dataType != a.dataType) =>
         i.makeCopy(Array(a, b.map(Cast(_, a.dataType))))
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -286,7 +286,7 @@ trait HiveTypeCoercion {`
`286`	`286`	`*/`
`287`	`287`	`object InConversion extends Rule[LogicalPlan] {`
`288`	`288`	`def apply(plan: LogicalPlan): LogicalPlan = plan transformAllExpressions {`
`289`		`- case i @ In(a, b) if b.exists(_.dataType != StringType) =>`
	`289`	`+ case i @ In(a, b) if b.exists(_.dataType != a.dataType) =>`
`290`	`290`	`i.makeCopy(Array(a, b.map(Cast(_, a.dataType))))`
`291`	`291`	`}`
`292`	`292`	`}`