我写了一个 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 依赖。
你能指导我解决这个问题吗?
任何帮助将不胜感激。
烙印99
相关分类