[jira] [Created] (FLINK-22641) flink 1.13.0 文档 Concepts 下的 Timely Stream Processing 目录下有关waterMark描述

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-22641) flink 1.13.0 文档 Concepts 下的 Timely Stream Processing 目录下有关waterMark描述

Shang Yuanchun (Jira)
金翔 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)