我寫了一個 Flink 程序來解析流式數據。我可以毫無問題地運行它。但是當我制作一個 jar 文件時,jar 文件沒有運行。要制作 jar 文件,我遵循以下路徑: Flile ---> Project Structure ---> Artifacts ---> jar ---> From modules with dependencies 我將 META-INF 的目錄更改為resources。之后,我構建了工件。構建了 jar 文件;盡管如此,我無法運行它。當我想運行它時,我收到此錯誤:線程“main”中的異常 java.lang.Exception:無法在 org.apache.flink.runtime.clusterframework.BootstrapTools 的 org.apache.flink.runtime.clusterframework.BootstrapTools.startActorSystem(BootstrapTools.java:276) 創建演員系統.startActorSystem(BootstrapTools.java:162) 在 org.apache.flink.runtime.metrics.util.MetricUtils.startMetricsActorSystem(MetricUtils.java:126) 在 org.apache.flink.runtime.minicluster.MiniCluster.start(MiniCluster.java :260) 在 org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:120) 在 org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1510) 在PooyaCo.App.main(App.java:38)Caused by: com.typesafe.config.ConfigException$Missing: 找不到鍵 'akka.remote.artery' 的配置設置奇怪的是,我按照上面的步驟為helloworld程序制作 jar 文件,并且 jar 文件運行沒有任何問題。我認為問題是因為 flink 依賴。你能指導我解決這個問題嗎?任何幫助將不勝感激。
添加回答
舉報
0/150
提交
取消