Re:Re: Flink Sql 1.13 UDF ERROR

2021-07-11 文章 Roc Marshal
Hi, Jingsong. 最新的类型推导相对于之前版本的类型推导更加严格,对schema的非空限制校验也更加细致。 在之前提到的例子中使用基本类型做UDF参数, 表示跟UDF中参数相关的列必须非空,而在创建视图时,每个类型默认的非空限制为false,因此出现了之前描述的问题。 祝好。 Best Roc. 在 2021-06-29 11:02:55,"Jingsong Li" 写道: >Hi, > >你可以创建个JIRA,让Timo看看,UDAF引入了新的类型推导,可能有问题 > >Best, >Jingsong > >On

Re: Flink Sql 1.13 UDF ERROR

2021-06-28 文章 Jingsong Li
Hi, 你可以创建个JIRA,让Timo看看,UDAF引入了新的类型推导,可能有问题 Best, Jingsong On Tue, Jun 29, 2021 at 7:10 AM Roc Marshal wrote: > > > Hi, All. > > > 请教一个在最新的1.13.1 api升级调研中遇到的问题,谢谢大家: > > > 版本: 1.13.1 > 运行模式: IDE-application > --- > about udf define...

Flink Sql 1.13 UDF ERROR

2021-06-28 文章 Roc Marshal
Hi, All. 请教一个在最新的1.13.1 api升级调研中遇到的问题,谢谢大家: 版本: 1.13.1 运行模式: IDE-application --- about udf define... public static class UDFAggregateFunction extends AggregateFunction { //返回最终结果 @Override public

Flink Sql 1.13 UDF ERROR

2021-06-28 文章 Roc Marshal
Hi, All. 请教一个在最新的1.13.1 api升级调研中遇到的问题,谢谢大家: 版本: 1.13.1 运行模式: IDE-application --- about udf define... public static class UDFAggregateFunction extends AggregateFunction { //返回最终结果 @Override public