Repository: flink Updated Branches: refs/heads/master 31b86f605 -> 5412baaf7
[FLINK-4565] [table] Support for SQL IN operator - move case of equal check This closes #4493. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5412baaf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5412baaf Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5412baaf Branch: refs/heads/master Commit: 5412baaf754964eb9b50199b306362afd5d5a8b0 Parents: 31b86f6 Author: tedyu <yuzhih...@gmail.com> Authored: Mon Aug 7 11:11:55 2017 -0700 Committer: twalthr <twal...@apache.org> Committed: Wed Aug 9 14:02:34 2017 +0200 ---------------------------------------------------------------------- .../main/scala/org/apache/flink/table/expressions/subquery.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/5412baaf/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/subquery.scala ---------------------------------------------------------------------- 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 index 32b9e46..6aef5c6 100644 --- 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) =>
