Soark-checkPoint

1.檢查點機制目標: 2.驅動程序容錯: 啓動失敗後重啓,會用getOrCreate方法從檢查點目錄初始化出StreamingContext 3.工作節點容錯: 1.最佳方式還是使用可靠的數據源(HDFS、拉式Flume等)。 2.提供exactly once語義,即使一個工作節點上的數據處理失敗, 容錯後得出的結果和之前是一樣的
相關文章
相關標籤/搜索
本站公眾號
   歡迎關注本站公眾號,獲取更多信息