Flink WaterMark機制

如果您正在構建實時流媒體應用程序，則事件時間處理是您必須遲早使用的功能之一。由於在大多數現實世界的用例中，消息到達無序，應該有一些方法，您建立的系統瞭解消息可能遲到並且相應地處理的事實。在這篇博文中，我們將看到爲什麼我們需要事件時間處理，以及我們如何在ApacheFlink中啓用它。 EventTime是事件在現實世界中發生的時間，ProcessingTime是Flink系統處理該事件的時間。要了

>>阅读原文<<