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