如何根据可用性优先选择一个流而不是另一个流？

Question

给定Flink中的两个流A和B，我想处理流A，直到它为空，然后开始读取B，直到有记录到达A。

我正在寻找一份宽松的合同。我发现，InputSelectable接口似乎提供了提供读取优先级的概念。

基于这个答案，我看到了流读取的循环实现。但是，从文档中我不确定如果其中一个流变空会发生什么情况？，操作员是否完全停止处理记录？

实现这一点的一种简单方法是在切换到较低优先级的流之前使用Timers轮询和检测Stream的不活动，但这可能效率太低。

Qs：

1. 是否有内置的流操作符来实现上述用例
2. 如果一个输入变为空，InputSelective的行为是什么
3. 基于定时器的输入可选择实现是一种可行的方法吗




Answer 1

答案：

1. 不。
2. 我不认为行为是指定/保证的。
3. 应该是可行的，但你需要小心。

您可能会因输入可选而陷入麻烦。如果您完全耗尽其中一个输入，将阻止检查点屏障对齐完成，从而阻止检查点。也可以构建死锁的拓扑。

您可能需要考虑网络缓冲区超时与计时器的交互作用。我想您可能希望将流A的网络缓冲区超时设置为小于计时器使用的超时。