首页 > 其他分享 >flink -udf函数(AggregateFunction)报错

flink -udf函数(AggregateFunction)报错

时间:2023-03-23 21:03:56浏览次数:32  
标签:函数 自定义 flink AggregateFunction 导包 报错

编写自定义函数AggregateFunction时,报错如下:

flink -udf函数(AggregateFunction)报错_导包

 最终发现是因为导包错误:

flink -udf函数(AggregateFunction)报错_应用场景_02

之后上网查了,发现这两个算子的应用场景不同:

flink -udf函数(AggregateFunction)报错_自定义函数_03


















标签:函数,自定义,flink,AggregateFunction,导包,报错
From: https://blog.51cto.com/u_15345945/6145950

相关文章