FlinkFlink 流计算 容错 source节点进行数据容错

Posted 2021-08-30 九师兄

1.概述

本博客是视频的笔记：Apache Flink 知其然，知其所以然（原理&实战）

就是当流任务失败的时候，如何让flink从数据源上次消费的位置开始消费。

2.案例

2.1 没有checkpoint

/**
     * 测试点：测试数据源 无 并行度 无checkpoint
     * 测试结果：
     * 
     * org.apach