吾忘 2022-05-27 11:13 采纳率: 100%
浏览 13
已结题

Flink处理乱序数据,关于测输出流的问题

现在需要使用Flink处理一批乱序数据,设置了一个十分钟的窗口从10:14:50-10:24:50,但是为什么10:14:51的数据会输出到测输出流中?

val aggStream = dataStream
      .filter(_.method == "GET")
      .keyBy(_.url)
      .timeWindow(Time.minutes(10), Time.seconds(5))
        .allowedLateness(Time.minutes(1)) //允许延迟
        .sideOutputLateData(new OutputTag[ApacheLogEvent]("late"))
      .aggregate(new PageCountAgg(), new PageViewCountWindowResult())

希望有朋友可以帮忙解答一下

  • 写回答

0条回答 默认 最新

    报告相同问题?

    问题事件

    • 已结题 (查看结题原因) 5月27日
    • 创建了问题 5月27日

    悬赏问题

    • ¥15 android studio导航图代码argument的name的ID红色
    • ¥15 P1口接8个发光二极管,利用定时计数器1编写程序
    • ¥20 keil5编译找不到.h文件该如何解决
    • ¥15 安卓EVS如何开启服务正常实现功能
    • ¥15 canal读取mysql时报错
    • ¥15 关于 S7-PLCSIM Advanced 5.0本地TCP连接无法读写数据
    • ¥15 关于温度改变石墨烯介电性能(关键词-介电常数)
    • ¥150 HDMI分路器LT86102 的输出在890MHz频点处EMC超标8DB
    • ¥15 druid(相关搜索:数据库|防火墙)
    • ¥15 大一python作业