全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

FlinkSQL中如何实现多流合并时的水印传播？

提问者：帅平问题分类：面试刷题

FlinkSQL面试题 Flink

发布于：1周前 (05-28) IP属地：

1 个回答

素手烹茶べ待君归

具体的实现方案有：
1、使用union合并流+统一水印策略：将多个流合并后，通过统一的WatermarkStrategy生成全局水印。

https://www.80wz.com/zb_users/upload/2025/05/20250528101423174839846314498.txt

2、使用CONNECT + 自定义水印策略：通过CONNECT操作符关联流，自定义WatermarkStrategy动态生成全局水印。

https://www.80wz.com/zb_users/upload/2025/05/20250528101612174839857280154.txt

发布于：1周前 (05-28) IP属地：

我来回答