Flink 自定义聚合函数 AggregateFunction 不触发-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

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

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

消息中间件 Kafka 流计算
分享到
取消 提交回答
全部回答(1)
  • pepsi1983
    2019-09-20 18:18:25

    你这问题解决了吗?我也出现这个问题。local不执行getresult,发布线上就能运行

    0 0
+ 订阅

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

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