我有一个 flink 作业（应用程序模式），其处理时间窗口聚合来自多个 kafka 主题的事件。这符合幸福之路的预期。
幸福的路径是简单地减少落入窗口的事件（在窗口到期之前）。自定义触发器用于检查减少所需事件已出现的条件。在这种情况下，返回 FIRE_AND_PURGE，这会导致将减少发布到接收器。
对于计时器到期场景（并且该窗口的所有必需事件尚未显示），flink 作业是否可以生成到接收器的备用输出？理想情况下，此故障路径输出可以使用迄今为止收集的事件，并（可以）使用它来生成此备用输出。有办法做到这一点吗？
快乐路径中的 flink 作业代码已创建并测试。它按预期工作。我在文档中找不到任何内容来显示如何让触发器的到期条件产生或设置某种状态，向减速器发出信号，表明它需要生成备用输出？