28 9 月 Flink, 大数据 Posted by 蓝染君 flink-40 Module操作 Module允许flink扩展函数能力 目前flink包含了以下三种module: Continue reading
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 月 未分类 Posted by 蓝染君 flink-31 容错机制 在flink中有一套完整的容错机制来保证故障后的恢复,其中最重要的就是检查点 检查点 ... Continue reading