可以藉由 streamingContext.checkpoint(checkpointDirectory) 函數來做。這運行之前介紹的有狀態transformation。另外,如果你想從driver故障中恢復,你應該以下面的方式重 ...
確定! 回上一頁