0

我正在运行一个 flink 应用程序,并希望我的 flink 应用程序引用在 flink 应用程序启动期间给出的外部属性文件。

我尝试了以下方法:-

flink run env.java.opts="-Dconfig.file='/home/knoldus/Azuga-`Projects/DataFilterService/src/main/resources/config.properties' " /home/knoldus/Azuga-`Projects/DataFilterService/target/FlinkKafkaStreaming-fatJar.jar


env.java.opts="-Dconfig.file='/home/knoldus/Azuga-Projects/DataFilterService/src/main/resources/config.properties" fink run /home/knoldus/Azuga-Projects/DataFilterService/target/FlinkKafkaStreaming-fatJar.jar
4

0 回答 0