当前位置:网站首页>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
边栏推荐
- Spark Tuning common configuration parameters
- RPC typical framework
- 【上云精品】节能提效!加速纺织业“智造”转型
- redis的dict的扩容机制(rehash)
- Ladder side tuning: the "wall ladder" of the pre training model
- Kingbasees plug-in ftutilx of Jincang database
- Kingbasees plug-in DBMS of Jincang database_ OUTPUT
- Design and implementation of university laboratory goods management information system based on SSH
- MySQL synchronous data configuration and shell script implementation
- 金仓KFS数据集中场景(多对一)部署
猜你喜欢
随机推荐
寿命分布 4种
Very important very important very important very important very important very important very important very important very important
元素定位不到的 9 种情况
Gaussdb others scenarios with high memory
Compilation of learning from Wang Shuang (1)
Handler、Message、Looper、MessageQueue
Detailed explanation of Spark's support source code for Yan priority
Query method and interrupt method to realize USART communication
Causes and solutions of over fitting
基于超算平台气象预警并行计算架构研究
How to realize the rich text editor function of mobile terminal
Is it safe to open a stock account on your mobile phone? Who can I open an account with?
Countdownlatch source code analysis
记一次给OpenHarmony提交代码的过程
Kingbasees plug-in DBMS of Jincang database_ RANDOM
牛客网:旋转数组
Dynamic programming to solve stock problems (Part 1)
Spark history server performance improvement (I) -- Application List
Sentinel integrated Nacos data source
基于SSH的高校实验室物品管理信息系统的设计与实现 论文文档+项目源码及数据库文件









