当前位置:网站首页>Flink batch key points (personal translation)
Flink batch key points (personal translation)
2022-06-25 11:39:00 【Direction_ Wind】
Event Time / Watermarks #: Based on this scheme , All registered timers will trigger at the end of the time , Ignore user defined WatermarkAssigners or WatermarkGenerators.
Processing Time #: We allow users to request the current processing time and register processing time timers, however , The same time as the event , All timers will trigger at the end of the input .
state: Configured statebackend End will be ignored ,keyed finish shuffle After the operation , Previous state Will be discarded ( I don't know. keyed state or Before operator state Of )( The translation may not be right )
Failure Recovery #: Different from the entire restart of the stream , Intermediate status data can still be used , Just restart the wrong part , Failed restart costs less
checkpoint: No checkpoints , Some features will not work :CheckpointListener, kafka Of EXACTLY_ONCE , StreamingFileSink’s OnCheckpointRollingPolicy
边栏推荐
- TCP如何处理三次握手和四次挥手期间的异常
- 仿真与烧录程序有哪几种方式?(包含常用工具与使用方式)
- SQL注入漏洞(类型篇)
- 牛客网:旋转数组
- 时创能源冲刺科创板:拟募资11亿 年营收7亿净利反降36%
- Double tampon transparent cryptage et décryptage basé sur le cadre minifilter
- GC
- A program reflecting the characteristics of C language program structure
- GC
- Geographic location system based on openstreetmap+postgis paper documents + reference papers + project source code and database files
猜你喜欢
JVM 原理简介
Spark history server and event log details
Crawler scheduling framework of scratch+scratch+grammar
Apache ShenYu 入門
Jincang KFS data cascade scenario deployment
基于C语言的图书信息管理系统 课程论文+代码及可执行exe文件
一个数学难题,难倒两位数学家
Apache ShenYu 入门
Golden sun education listed in the U.S.: a small cap medium cap stock with a market value of USD 360million
记一次给OpenHarmony提交代码的过程
随机推荐
How to start the phpstudy server
GC
Semaphore source code analysis
Comparator (for arrays.sort)
redis的dict的扩容机制(rehash)
[维护集群案例集] GaussDB 查询用户空间使用情况
C disk uses 100% cleaning method
Double buffer transparent encryption and decryption driven course paper + project source code based on minifilter framework
Kingbasees plug-in DBMS of Jincang database_ RANDOM
动态规划解决股票问题(上)
基于超算平台气象预警并行计算架构研究
Detailed explanation of spark specification
Spark runs wordcount (case 1)
Gaussdb cluster maintenance case set - slow SQL execution
RPC typical framework
手机上股票开户安全吗?找谁可以开户啊?
建造者模式
Writing wechat applet with uni app
Arrays.asList()
Why distributed IDS? What are the distributed ID generation schemes?