Spark Streaming checkpoint的問題與恢復

/**雖然checkpoint是對Spark Streaming運行過程當中的元數據和每次RDD的數據狀態 * 保存到一個持久化系統中,實現高可用性。 * 即便 * /**當程序修改後打包成新程序後,可能會報錯,若刪除checkpoint的開頭文件,只保留數據文件: * hadoop dfs -rmr /checkpoint/checkpoint* * 可是新程序雖然能從
相關文章
相關標籤/搜索