我們以[1]中代碼為主,首先進行scala實驗,然后再進行java實驗

步驟	內容
①	mvn clean scala:compile compile package
②	nc -lk 9999 flink run -c StateWordCount /home/appleyuchi/桌面/Flink_Code/flink_state/checkpoint/Scala/target/datastream_api-1.0-SNAPSHOT.jar   連續4次故意輸入error來觸發job停止(模擬生產環境中的大數據框架崩潰) 44444444 44444444 error error error error
③	崩潰后我們去WEB UI中看到下面的效果,點進去   選擇checkpoints然后復制頁面的中間一行

總結

以上是生活随笔為你收集整理的flink的checkpoint实验-scala版本的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。