当前位置:网站首页>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

原网站

版权声明
本文为[Direction_ Wind]所创,转载请带上原文链接,感谢
https://yzsam.com/2022/02/202202200537152725.html