Flink WaterMark机制

如果您正在构建实时流媒体应用程序，则事件时间处理是您必须迟早使用的功能之一。由于在大多数现实世界的用例中，消息到达无序，应该有一些方法，您建立的系统了解消息可能迟到并且相应地处理的事实。在这篇博文中，我们将看到为什么我们需要事件时间处理，以及我们如何在ApacheFlink中启用它。 EventTime是事件在现实世界中发生的时间，ProcessingTime是Flink系统处理该事件的时间。要了

>>阅读原文<<