28 9 月 Flink, 大数据 Posted by 蓝染君 flink-37 Flink sql 时间属性 所谓的时间属性,其实就是每个表schema的一部分,它可以在创建表的DDL里直接定义一个字段,也可以在DataStream转换成表时定义。 Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-36 流处理中的表 动态表(Dynamic Tables) 当流中有新数据到来,初始表中会插入一行,而基于这个表定义的SQL查询,就应该在之前的基础上更新... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-34 状态一致性 端到端一致性 状态一致性 一致性其实就是结果的正确性,一般从数据丢失、数据重复来评估 Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-33 保存点 除了检查点,flink还提供了另一个非常独特的镜像保存功能:保存点(savepoint) 这也时一个存盘的备份,原理和算法与检查点完全... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-32 检查点配置 启用检查点 默认情况下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