This is an automated email from the ASF dual-hosted git repository. snuyanzin 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 ef2b626d671 [FLINK-33779][table] Cleanup usage of deprecated BaseExpressions#cast ef2b626d671 is described below commit ef2b626d67147797e992ec3b338bafdb4e5ab1c7 Author: Jacky Lau <liuyon...@gmail.com> AuthorDate: Sat Dec 16 06:59:10 2023 +0800 [FLINK-33779][table] Cleanup usage of deprecated BaseExpressions#cast --- .../apache/flink/table/planner/plan/stream/table/AggregateTest.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/table/AggregateTest.scala b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/table/AggregateTest.scala index ade4c8b1f03..829ea0ba9fb 100644 --- a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/table/AggregateTest.scala +++ b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/table/AggregateTest.scala @@ -123,7 +123,7 @@ class AggregateTest extends TableTestBase { val resultTable = table .groupBy('b) - .select('b, 'a.cast(BasicTypeInfo.DOUBLE_TYPE_INFO).avg) + .select('b, 'a.cast(DataTypes.DOUBLE()).avg) util.verifyExecPlan(resultTable) }