社区版的Flink的AggregateFunction的Open函数不被调用?-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

社区版的Flink的AggregateFunction的Open函数不被调用?

stevenchennet 2018-11-13 11:03:56 1934

flink-1.4.2 (使用1.6.2测试过,问题同样存在)
自定义一个AggregateFunction,需要在open函数中做一些处理,Intellij调试的时候发现open函数不被调用。
由于计算逻辑较复杂,同样用到了udsf和udtf,这两个对象的open函数在调试的时候是可以被调用的,但是udaf的open函数打了断点也进不去。

是不是udaf不是一个richfunction,open不起作用啊?
udaf

流计算
分享到
取消 提交回答
全部回答(1)
  • 健东
    2019-07-17 23:13:49

    应该不是这里的问题

    0 0
大数据
使用钉钉扫一扫加入圈子
+ 订阅

大数据计算实践乐园,近距离学习前沿技术

推荐文章
相似问题