flink数据聚合遇到的数据过热，延迟数据丢弃， 反压等问题如何解决

首先解释一下数据过热、延迟数据丢弃和数据反压的产生原因： 1.数据过热原因： 实时处理中的关键问题是检测数据流中的事件模式。复杂事件处理（CEP）恰好解决了对连续传入事件进行模式匹配的问题。 匹配的结果通常是从输入事件派生的复杂事件。 与对存储数据执行查询的传统DBMS相比，CEP在存储的查询上执行数据。 可以立即丢弃与查询无关的所有数据。 考虑到CEP查询应用于潜在的无限数据流，这种方法的优势是

>>阅读原文<<