Apache Flink-如何指定外部应用程序.conf文件



i有一个flink流媒体应用程序,该应用程序已在JAR中使用application.conf文件开发。但是,我希望能够明确指定外部应用程序。

flink run -m yarn-cluster -yid "appName" -yD "env.java.opts=-Dconfig.file=/path/to/application.conf" -yn 1 -yjm 1024 -ytm 7000 -p 8 -d /usr/lib/flink/lib/MyFlinkApp.jar

但是,JAR中的配置仍在使用。有人可以确定我在做什么吗?

预先感谢。

为什么不将配置文件添加到"资源"dict并将其包装到jar中,然后您可以在flink中访问文件,如下:

getClass.getResourceAsStream("/you-conf.file")

相关内容

  • 没有找到相关文章

最新更新