You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2019/07/15 01:49:19 UTC
[flink] branch master updated: [FLINK-13229][table-planner-blink]
ExpressionReducer with udf bug in blink (#9091)
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new a5812688 [FLINK-13229][table-planner-blink] ExpressionReducer with udf bug in blink (#9091)
a5812688 is described below
commit a5812688d254c174153f5f46876311153795714e
Author: Jingsong Lee <lz...@aliyun.com>
AuthorDate: Mon Jul 15 09:49:01 2019 +0800
[FLINK-13229][table-planner-blink] ExpressionReducer with udf bug in blink (#9091)
---
.../scala/org/apache/flink/table/runtime/batch/sql/CalcITCase.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/sql/CalcITCase.scala b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/sql/CalcITCase.scala
index 130042e..1e4279c 100644
--- a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/sql/CalcITCase.scala
+++ b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/sql/CalcITCase.scala
@@ -300,8 +300,8 @@ class CalcITCase extends BatchTestBase {
registerCollection("MyTable", data, new RowTypeInfo(STRING_TYPE_INFO), "text")
checkResult(
- "SELECT hashCode(text) FROM MyTable",
- Seq(row(97), row(98), row(99)
+ "SELECT hashCode(text), hashCode('22') FROM MyTable",
+ Seq(row(97,1600), row(98,1600), row(99,1600)
))
}