Structured Streaming容错

我看官方文档说Structured Streaming是通过checkpoint和WAL来保证容错的，并且通过数据源的可重复消费以及幂等来保证端到端的exactly-once。但是如果对程序修改了，重新启动的时候，读取checkpoint目录数据是不是也引起序列化问题。还有一个疑问，checkpoint和wal分别是保存什么的？

checkpoint有点像做快照，出现故障了，从快照开始恢复wal：是预写日志，就是写数据之前，先写日志，数据丢了，根据日志恢复数据。

bioger_hit 发表于 2018-7-25 12:52
checkpoint有点像做快照，出现故障了，从快照开始恢复wal：是预写日志，就是写数据之前，先写日志，数据丢 ...

那就是checkpoint存储应用的元数据，wal存储offset？