开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

一个Flink SQl的job中,消费同一个kafka,使用滚动窗口计算每小时的统计,使用渐进式窗?

一个Flink SQl的job中,消费同一个kafka,使用滚动窗口计算每小时的统计,使用渐进式窗口计算零点到当前的统计;现在遇到一个问题:
滚动窗口计算 需要设置 table.exec.emit.early-fire.enabled = true; table.exec.emit.early-fire.delay = 10000; 也就是每10秒去触发计算一次(因为页面要展示,不能每一个小时计算一次)
但是 渐进式窗口 不允许设置 table.exec.emit.early-fire.enabled
该怎么办呀?我想的是 分开两个 flink sql job来处理;但 这就要创建两个 kafka的source,是不是比较浪费啊?

展开
收起
真的很搞笑 2023-08-20 19:26:09 109 0
1 条回答
写回答
取消 提交回答
  • 1个小时的滑动窗口,每10秒滑动一次,还想用flink的话,用CUMULATE窗口比较满足你的需求,此回答整理自钉群“【③群】Apache Flink China社区”

    2023-08-20 19:33:04
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    SQL Server在电子商务中的应用与实践 立即下载
    GeoMesa on Spark SQL 立即下载
    原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载