UNION一侧为空时Azure Stream Analytics无输出问题咨询

问题成因 #

你遇到的输出阻塞问题和UNION的逻辑语义无关，核心是Azure流分析（ASA）的流处理时间特性导致的：

• ASA为每个查询分支独立维护水印（表示该分支已处理到的安全时间点，晚于该时间的事件不会再到达），合并多分支输出时，默认会取所有分支水印的最小值作为合并后输出的统一水印，只有最慢的分支水印推进到对应时间点，该时间点之前的所有合并结果才会向下游输出。
• 你的查询中，VermogenAandrijvingMeasurements是5分钟高频输出分支，水印推进速度快；WaterLevelTopMeasurements依赖闸门开关触发，每日仅产生几次数据，水印长期停留在旧时间点，导致高频分支的输出被持续阻塞，直到低频分支产生新数据更新水印，才会统一输出所有积压的结果。
• 额外加剧延迟的问题：你当前使用UNION而非UNION ALL，UNION需要对合并结果做全局去重，会引入额外的等待窗口，拉长输出延迟。

修复方案 #

方案1：拆分作业从输出侧合并（最稳定） #

将高频分支和低频分支拆分为两个独立的ASA作业，分别写入同一个接收器（如数据湖同一路径、同一事件中心等），不需要在作业内做UNION操作，从输出层实现结果合并，彻底避免分支水印互相阻塞的问题。

方案2：调整水印推进策略（无需拆作业） #

对作业添加空闲水印自动推进配置，强制低频分支即使没有新数据，也能定期推进水印：

1. 在作业查询开头添加配置：ALTER DATABASE <你的作业数据库名> SET DELAYED_DURATION_WHEN_IDLE = '00:05:00'，表示空闲时每5分钟自动推进一次水印，避免低频分支长期卡住整体输出。
2. 将查询最后的UNION改为UNION ALL，你的两个分支输出的MeasurementName完全不同，不存在重复数据，用UNION ALL可以省去去重的等待开销，大幅降低输出延迟。

方案3：补充低频分支占位事件（兼容性最好） #

在事件源侧定期向Event Hub发送低频分支对应的占位事件，事件内容可以为空，查询中新增过滤规则排除占位事件即可，相当于用模拟事件推进低频分支的水印，不会污染最终输出。

内容的提问来源于stack exchange，提问作者Leon Cullens