有没有思考过这样的问题–在flink内部使用的分布式快照算法保证一致性的问题,那在flink运行的shangxiawen组件中一致性是怎么保证的呢?flink内–checkpoint
实际生产中必须考虑端端一致性的保证,他的一致性级别取决于所有流程中一致性最弱的组件 预写日志:针对于非关系型数据库–如es redis等 两阶段提交:针对于关系型数据库