28 9 月 Flink, 大数据 Posted by 蓝染君 flink-32 检查点配置 启用检查点 默认情况下flink是禁用检查点的,如果要开启需要在代码中显示的调用 Continue reading
28 9 月 未分类 Posted by 蓝染君 flink-31 容错机制 在flink中有一套完整的容错机制来保证故障后的恢复,其中最重要的就是检查点 检查点 ... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-30 状态后端 在flink中状态的存储、访问以及维护,都是由一个可拔插的组件决定:状态后端(state backend) 状态后端主要复制管理本地状... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-29 算子状态 算子状态就是一个算子并行实例上定义的状态,作用范围被限定为当前算子任务 算子状态的实际应用场景不如K... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-27 状态管理 在flink中算子任务,可以分为无状态和有状态两种 无状态的算子任务只需要观察每个独立事件,根据当前输入的数据直接转换输出结果。之前讲... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-25 窗口处理函数 思路一: 所有数据到一起,用hashmap存储, key=vc,value=count值 ... Continue reading