首页 > 其他分享 >Flink - [05] 时间语义 & Watermark

Flink - [05] 时间语义 & Watermark

时间:2024-06-17 16:14:23浏览次数:23  
标签:05 Flink watermark 时间 Watermark Time 乱序

题记部分

 

一、时间语义

Flink中的时间语义分为以下,

(1)Event Time:事件创建的时间

(2)Ingestion Time:数据进入Flink的时间

(3)Processing Time:执行操作算子的本地系统事件,与机器相关

 

哪种时间语义更重要?

  • 不同的时间语义有不同的应用场合,我们往往更关心事件时间(Event Time)
  • 某些场合,不应该使用Processing Time
  • Event Time可以从日志数据的时间戳(timestamp)中提取
2017-11-02 18:37:15.624 INFO Fail over to rm

 

1.1、设置Event Time

可以直接在代码中,对执行环境调用setStreamTimeCharacteristic方法,设置流的时间特性

具体的时间,还需要从数据中提取时间戳(timestamp)

val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)

 

1.2、乱序数据的影响

(1)当Flink以Event Time模式处理数据流时,它会根据数据里的时间戳来处理基于时间的算子

(2)由于网络、分布式等原因,会导致乱序数据的产生

(3)乱序数据会让窗口计算不准确

 

 

二、Watermark(水位线)

(1)怎样避免乱序数据带来计算不正确?

(2)遇到一个时间戳达到了窗口关闭窗口,不应该立刻触发窗口计算,而是等待一段时间,等迟到的数据来了再关闭窗口

 

Watermark是一种衡量Event Time进展的机制,可以设定延迟触发

Watermark是用于处理乱序事件的,而正确的处理乱序事件,通常用Watermark机制结合window来实现。

数据流中的Watermark用于表示timestamp小于Watermark的数据都已经到达了,因此,window的执行也是由Watermark触发的。

watermark用来让程序自己平衡延迟和结果正确性。

 

2.1、Watermark的特点

(1)watermark是一条特殊的数据记录

(2)watermark必须单调递增,以确保任务的事件时间时钟在向前推进,而不是在后退

(3)watermark与数据的时间戳相关

 

2.2、watermark的传递

 

2.3、watermark的引入

Event Time的使用一定要指定数据源中的时间戳

调用.assignTimestampsAndWatermarks()方法,传入一个BoundedOutOfOrdernessTimestampExtractor,就可以指定watermark

dataStream.assignTimestampsAndWatermarks(
    new BoundedOutOfOrdernessTimestampExtractor[SensorReading]
    (Time.milliseconds(1000)){
        override def extractTimestamp(element: SensorReading): Long = {
            element.timestamp * 1000
        }
    }
)

对于排好序的数据,不需要延迟触发,可以只指定时间戳就行了

dataStream.assignAscendingTimestamps(_.timestmap * 1000)

Flink暴露了TimestampAssigner接口供我们实现,使我们可以自定义如何从事件数据中抽取时间戳和生成watermark

dataStream.assignTimestampsAndWatermarks(new MyAssigner())

MyAssigner可以有两种类型,都继承自TimestampAssigner

 

 

2.4、TimestampAssigner

定义了抽取时间戳,以及生成watermark的方法,有两种类型,

(1)AssignerWithPeriodicWatermarks

  ① 周期性的生成watermark:系统会周期性的将watermark插入到流中

  ② 默认周期是200毫秒,可以使用ExecutionConfig.setAutoWatermarkInterval()方法进行设置

  ③ 升序和前面乱序的处理BounderOutOfOrderness,都是基于周期性watermark的

(2)AssignerWithPunctuatedWatermarks:没有时间周期规律,可打断生成watermark

 

 

2.5、watermark的设定

  在Flink中,watermark由应用程序开发人员生成,这通常需要对相应的领域有一定的了解。如果watermark设置的延迟太久,收到结果的速度可能就会很慢,解决办法是在水位线到达之前输出一个近似结果。而如果watermark到达太早,则可能收到错误结果,不过Flink处理延迟数据的机制可以解决这个问题。

 

 

 

— 业精于勤荒于嬉,行成于思毁于随 —

标签:05,Flink,watermark,时间,Watermark,Time,乱序
From: https://www.cnblogs.com/houhuilinblogs/p/18252607

相关文章

  • Flink - [03] API
    使用scala编写flinkapi从不同的数据源(源端)读取数据,并进行无界流/有界流的数据处理,最终将处理好的数据sink到对应的目标端 一、maven配置<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.or......
  • 程序员修炼之道:从小工到专家阅读笔记05
    程序员所应该遵循的实用主义原则。 我的源码让猫给吃了:出现错误时,要诚实,不要推诿或者找借口。要提供各种可能的解决方案与后果并与他人沟通,而不是提供借口。 软件的熵:这是著名的破窗户原理。项目中一个小的、无人料理的问题可能带来后续编码时的懈怠,从而造成更大的问题。不......
  • LAETUS LLS570-05 激光扫描仪
    LLS570-05特点:高速扫描和检测:LLS570-05激光扫描仪具有快速的扫描速度和高精度的检测能力,能够快速而准确地进行产品表面的检测和分析。表面缺陷检测:该扫描仪可用于检测产品表面的各种缺陷,如裂纹、凹陷、污点、异物等,确保产品质量符合规定标准。条形码和字符识别:LLS570-05还......
  • Flink面试必问题:时间和窗口处理面试题及参考答案(3万字长文)
    目录Flink中的事件时间(EventTime)和处理时间(ProcessingTime)有什么区别?Flink的容错机制是如何实现的?Flink中的窗口(Window)是什么?Flink支持哪些类型的窗口?如何定义一个滚动窗口(TumblingWindow)?如何定义一个滑动窗口(SlidingWindow)?如何定义一个会话窗口(SessionWindow)?Flin......
  • 2023年05月二级
    青少年软件编程(图形化)等级考试试卷(二级)一、单选题(共25题,共50分)1.运行下列哪段程序,可以让狗狗走到木屋门口?( )A. B. C. D. 试题编号:20220501wyh04-001试题类型:单......
  • 【flink实战】flink-connector-mysql-cdc导致mysql连接器报类型转换错误
    文章目录一.报错现象二.方案二:重新编译打包flink-connector-cdc1.排查脚本2.重新编译打包flink-sql-connector-mysql-cdc-2.4.0.jar3.测试flink环境三.方案一:改造flink连接器一.报错现象flinksql任务是:mysql到hdfs的离线任务,flink在消费mysql时报如上错误......
  • 0055-跳跃游戏
    55.跳跃游戏给你一个非负整数数组nums,你最初位于数组的第一个下标。数组中的每个元素代表你在该位置可以跳跃的最大长度。判断你是否能够到达最后一个下标,如果可以,返回true;否则,返回false。示例1:输入:nums=[2,3,1,1,4]输出:true解释:可以先跳1步,从下标0到达下标......
  • WPF customized Image control can add watermark , save and restore
     //usercontrol//xaml<UserControlx:Class="WpfApp173.ImageZoomPanWatermark"xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml&quo......
  • 冲刺05
    activity_parent.xml<?xmlversion="1.0"encoding="UTF-8"?><LinearLayoutxmlns:android="http://schemas.android.com/apk/res/android"xmlns:app="http://schemas.android.com/apk/res-auto"android:layo......
  • 05-5.3.1_1 二叉树的先中后序遍历
    ......