logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

kafka主题支持路由功能

kafka路由kafka模拟rabbitmq路由设计

文章图片
#kafka#分布式
flink的watermark简单理解

1.flink的watermark的作用是处理乱序,核心有两点:a.延迟等待一段时间,等乱序的数据到达b.不能一直等,得有个限度,到了时间点没到,那么后面再来的乱序数据只能丢弃2.对某个时间窗开始统计的依据是:a.watermark>window.endtimeb.[window.starttime,window.endtime)里面有数据3.假设Event1到达,对应的时间窗口是[star

flink的KeyedBroadcastProcessFunction测试

flink的KeyedBroadcastProcessFunction状态测试

文章图片
#flink#java#log4j
    共 65 条
  • 1
  • 2
  • 3
  • 7
  • 请选择