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")