flink的savepoint实验-scala
大致步驟同[1]
?
| 步驟 | 步驟內容 |
| ① | 啟動Zookeeper,Hadoop,Flink(HA)三種集群(啟動順序不要錯) |
| ② | mvn clean scala:compile compile package cd target flink run -c WordCount /home/appleyuchi/桌面/Flink_Code/flink_state/savepoint/Scala/target/datastream_api-1.0-SNAPSHOT.jar ? Job has been submitted with JobID 657e2ab956cc57c2e01cc618b8bf3b03 |
| ③ | flink savepoint 657e2ab956cc57c2e01cc618b8bf3b03 Triggering savepoint for job 657e2ab956cc57c2e01cc618b8bf3b03. |
| ④ | flink cancel 657e2ab956cc57c2e01cc618b8bf3b03 Cancelling job 657e2ab956cc57c2e01cc618b8bf3b03. Cancelled job 657e2ab956cc57c2e01cc618b8bf3b03. |
| ⑤ | flink run -s hdfs://Desktop:9000/flink-savepoints/savepoint-657e2a-be30c75ec137?-c WordCount -d /home/appleyuchi/桌面/Flink_Code/flink_state/savepoint/Scala/target/datastream_api-1.0-SNAPSHOT.jar |
具體實驗效果可以參考[1]
完整代碼
?
?
Reference:
[1]flink的savepoint實驗-java
總結
以上是生活随笔為你收集整理的flink的savepoint实验-scala的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 提心吊胆是什么意思（不明原因的长时间提心
- 下一篇： jsp+tomcat程序hellowor