金翔 created FLINK-22641:
--------------------------

             Summary: flink 1.13.0 文档 Concepts 下的 Timely Stream Processing 
目录下有关waterMark描述
                 Key: FLINK-22641
                 URL: https://issues.apache.org/jira/browse/FLINK-22641
             Project: Flink
          Issue Type: Improvement
          Components: Documentation
            Reporter: 金翔
         Attachments: image-2021-05-12-14-32-08-269.png, 
image-2021-05-12-15-01-44-125.png

     在flink 1.13.0 文档中,Concepts 标题下的 *Timely Stream Processing*  实时流处理 文档描述

 [Event time and 
Watermarks|https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/concepts/time/#event-time-and-watermarks]
  乱序流中waterMark和event 
时间戳的乱序应稍微调整一下,因为waterMark到达以后表示的是当前的时间戳之前的数据都已经到达,在W(11)分界线的时候,后面是 E(14),而在之前有 
E(15),在单流中显然不太合理,同理在 W(17)的后面是E(19),而在之前有 
E(22)和E(20)两条event。waterMark处理乱序和运行延迟的到达的情况下,建议将E(14)和E(15)调换位置,同理在 
W(17)的地方,E(19)和E(20)调换位置同时将E(22)和E(12)去掉或者换成其他的event时间戳,修改的图也粘贴在附件中,谢谢!!!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to