标签: state | 程序员笔记

互动

最近评论

标签

寻找感兴趣的领域

文章

跳表 1 事务 1 clickhouse 1 数据传输 1 MemoryManagment 1 Slot 1 HA 1 Akka 1 RPC 1 ExecutionGraph 1 JobGraph 1 源码分析 3 StreamGraph 1 savepoint savepoint 1 ConcurrentHashMap 1 ORC 1 snapshot 1 ABS算法 1 lock 2 thread 1 kafka-producer 1 kafkaproducer partition 1 cgroup 1 HBase 1 LSM 2 B+树 1 SecondaryNmenode 1 NameNode 1 令牌桶 1 Guava 1 Flink CDC 1 Flink SQL 4 最佳实践 6 资源管理 2 维度表 1 调度 4 流批一体 2 join 2 Chain 1 Operator 1 ClassLoader 1 RocksDB 2 time 2 window 2 checkpoint 8 网络优化 1 watermark 3 背压 2 CEP 1 Shuffle 3 精确一致性 3 窗口 1 kafka-consumer 2 view 1 transformation 1 state 10 kudu 2 impala 2 内存管理 4 GC 1 Exception 1 多线程 1 YARN 1 MapReduce 2 HDFS 2 hadoop 0 Halo 0

Flink 的状态管理和检查点机制

bigdataflink 未读

Flink 的状态管理和检查点机制

从状态说起状态 (State) 是 Flink 程序中构建复杂逻辑的基本组件。流处理中的状态可以视作算子上的记忆能力，可以保留和已经处理完的输入相关的信息，并对后续输入的处理造成影响。与之相反，流处理中的无状态操作只会考虑到当前处理的元素，不会受到处理完毕的元素的影响，也不会影响到后续待处理的元素

checkpoint savepoint state 2019-08-05