You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2017/08/09 12:08:09 UTC
flink git commit: [FLINK-4565] [table] Support for SQL IN operator -
move case of equal check
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 <yu...@gmail.com>
Authored: Mon Aug 7 11:11:55 2017 -0700
Committer: twalthr <tw...@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) =>