开发者社区> 问答> 正文

Flink 自定义聚合函数 AggregateFunction 不触发

本地sock测试AggregateFunction 生效 但是上了flink集群后(连接的kafka源 ,数据能正常收到) 发现AggregateFunction 的getresult方法不触发,而createAccumulator和add均能触发,

分享到
取消 提交回答
全部回答(0)
+ 订阅

构建可靠、高效、易扩展的技术基石

推荐文章
相似问题
推荐课程