第132课： Spark Streaming源码经典解读系列之七：Executro容错工作内幕源码解密

第132课：  Spark Streaming源码经典解读系列之七：Executro容错工作内幕源码解密

Executor 容错高可用：

备份方式

1、备份：将数据拷贝一份，不同机器A/B两个进程复制一份副本，进程级别。

2、使用WAL备份方式，内存的数据挂掉，通过WAL恢复数据。

不备份的方式：

1、重放，从hdfs上重新读取数据，spark streaming可从kafka中读取数据。

2、忽略掉丢失的数据，不在意丢失1%的数据。使用适配器模式，构造一个空数据的集合，有无数据对计算结果无影响。RDD感知不到数据的变化。

这样运行不报错。