在 Flink 中将带水印的流与另一个不带水印的流连接

Question

我在 Flink 中有流 A 和流 B。

• A 有水印和时间戳
• B 是我通过定期调用 API 获得的一些来源，它没有水印/时间戳

我想连接流A和流B（用B丰富A），结果连接具有A的水印

由于 Flink 取两者之间的最小值，我考虑了两种方法：

1. 发出最大水印，并从 B 收集最大时间戳
2. 每次发射后将 B 标记为临时空闲

我不知道哪种方法是正确的，或者是否有更好的方法来处理这种情况

Answer 1

考虑到这种情况，根本不清楚为什么需要水印。使用 flink-http-connector 的查找连接将是一种替代方案，或者 async 输入/输出。