必会:关于SparkStreaming checkpoint那些事儿

spark Streaming的checkpoint是一个利器，帮助在driver端非代码逻辑错误导致的driver应用失败重启，比如网络，jvm等，当然也仅限于支持自动重启的集群管理器，比如yarn。由于checkpoint信息包含序列化的Scala / Java / Python对象，尝试使用新的修改类反序列化这些对象可能会导致错误。 本文主要讲解checkpoint使用的一些注意事项。 系统

>>阅读原文<<