Flink时间语义与Watermark_2.时间语义与分区等待watermak调优。避免多个分区因为等待watermark造成处理积压-CSDN博客

网站介绍:文章浏览阅读231次。一、Flink时间语义在 Flink 的流式处理中,会涉及到时间的不同概念,如下图所示: Event Time:是事件创建的时间。它通常由事件中的时间戳描述,例如采集的日志数据 中,每一条日志都会记录自己的生成时间,Flink 通过时间戳分配器访问事 件时间戳。 Ingestion Time:是数据进入 Flink 的时间。 Processing Time:是每一个执行基于时间操作的..._2.时间语义与分区等待watermak调优。避免多个分区因为等待watermark造成处理积压