在Flink中加入历史记录数据时，一个来源比另一侧要慢得多

Question

使用EventTime在JOIN Operator中消费历史记录数据时，从一个源读取数据比另一个来源慢得多。结果，加入运算符将从更快的源中缓存大量数据，以便等待较慢的源。

问题是，我该如何使消费者的速度较小？

Answer 1

我不确定我理解您的意思。如果您想避免缓存大量数据，并且无法控制源速度，那么我认为您唯一的选择是使用较小的窗口，以便减少数据的缓存。有关此的更多详细信息，请参见窗口加入。