栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

flink批处理关键点(个人翻译)

flink批处理关键点(个人翻译)

Event Time / Watermarks #:基于此方案,所有注册的定时器将在时间结束时触发,忽略用户自定义WatermarkAssigners or WatermarkGenerators。
Processing Time #:我们允许用户请求当前处理时间并注册processing time timers,但是,与事件时间一样,所有计时器都将在输入结束时触发。
state:配置的statebackend端将被忽略,keyed 做完shuffle操作后,之前的state的状态就会丢弃(不知道是keyed state的还是 之前operator state的)(翻译的不一定对)
Failure Recovery #:不同于流整个重启,中间状态的数据还是可以用的,只重启错了那部分就行,失败重启花费更小
checkpoint:没有检查点,一些功能将不起作用:CheckpointListener, kafka的EXACTLY_onCE , StreamingFileSink’s OnCheckpointRollingPolicy

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/650677.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号