[FLINK-4565] [table] Support for SQL IN operator - move case of equal…

… check This closes apache#4493.
spotify · Aug 9, 2017 · 5412baa · 5412baa
1 parent 31b86f6
commit 5412baa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/subquery.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/subquery.scala
@@ -64,8 +64,8 @@ case class In(expression: Expression, elements: Seq[Expression]) extends Express
  s"The sub-query table '$name' must not have more than one column.")
  }
  (expression.resultType, tableOutput.head.resultType) match {
- case (lType, rType) if isNumeric(lType) && isNumeric(rType) => ValidationSuccess
  case (lType, rType) if lType == rType => ValidationSuccess
+ case (lType, rType) if isNumeric(lType) && isNumeric(rType) => ValidationSuccess
  case (lType, rType) if isArray(lType) && lType.getTypeClass == rType.getTypeClass =>
  ValidationSuccess
  case (lType, rType) =>