如何解决Apache Flink-添加触发器会严重影响性能
我想实现一个同时具有计数限制和时间限制的窗口。 我发现此StackOverflow线程显示了这样做的实现。
在我的代码中,我通过以下方式创建窗口:
ds.timeWindow(Time.seconds(timeSeconds)).trigger(new CountTriggerWithTimeout[K,TimeWindow](count,env.getStreamTimeCharacteristic)).
当我查看管道的处理速率时,每秒大约有1.3K个事件。 但是,当我删除触发器并仅使用一个时间窗口时,就像这样:
ds.timeWindow(Time.seconds(timeSeconds))
我的处理速度高达每秒5.5K个事件。
我做错了什么(触发器实现是从链接线程中执行的)还是添加触发器如此严重地影响性能是正常的?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。