Spark Streaming checkpoint的问题与恢复

/**虽然checkpoint是对Spark Streaming运行过程当中的元数据和每次RDD的数据状态 * 保存到一个持久化系统中,实现高可用性。 * 即便 * /**当程序修改后打包成新程序后,可能会报错,若删除checkpoint的开头文件,只保留数据文件: * hadoop dfs -rmr /checkpoint/checkpoint* * 可是新程序虽然能从
相关文章
相关标签/搜索