前言
Flink使用Web UI可以方便本地除錯,基本使用如下:
pom添加
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-runtime-web_${scala.version}</artifactId>
<version>${flink.version}</version>
</dependency>
代碼中使用createLocalEnvironmentWithWebUI創建
Configuration conf = new Configuration();
StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf);
之前挺正常的,今天突然遇到一個奇怪的問題,雖然找到了解決方案,暫時解決了,但是還是沒有搞懂為什么會提示這個錯誤,所以記錄一下,
答案寫在最前面,后面的就是記錄一下自己的排錯:
conf.setString(RestOptions.BIND_PORT, "8081-8089");
配置一個可系結的埠范圍就能正常使用了,
Could not start rest endpoint on any port in port range 8081
這個錯誤就是說埠8081被占用了,所以目前的行程系結不上了,
第一反應就是上一次的埠估計沒有被釋放,所以正常來說一下兩步就解決了,
losf -i:8081
kill -9 xxx
但是!!!! 8081 沒有占用啊,,,
找到好久,發現可以在配置里面添加一個埠系結的范圍就嘗試了一下,,
結果成功了,,,,看日志,我去系結的埠是8081!!!!
雖然根據上述方法解決了,但是誰來告訴我為什么???
總結
這個問題放這里,以后再看,可以誰能告訴我為什么???
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/253060.html
標籤:其他
上一篇:datax增量抽取mongoDB
