(flink) branch master updated: [FLINK-33779][table] Cleanup usage of deprecated BaseExpressions#cast

[snuyanzin]

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)
   }