Flink run提交參數
折騰了好幾天,終於搞定了Flink run提交參數,記錄一下。
背景:
之前一直報錯,akka,AskTimeoutException,嘗試添加akka.ask.timeout=120000s, 依然顯示該錯誤。
後來在Flink官網找到了該參數的賦值方式,注意這裡有個大坑,數字和時間單位之間,必須有個空格。
shell腳本如下,具體數值大家可以自己根據實際情況調節:
flink run \ -m yarn-cluster \ -ynm applicaiton-name \ -yqu queue \ -p 4000 \ -ys 4 \ -yjm 10g \ -ytm 10g \ -yD akka.client.timeout="120000 s" \ -yD akka.ask.timeout="120000 s" \ -yD web.timeout=120000 \ -yD rest.retry.max-attempts=100 \ -c your-class \ your-jar your-input your-output