scala application.conf文件未从flink环境加载变量

vcudknz3  于 2021-06-24  发布在  Flink
关注(0)|答案(0)|浏览(186)

test-app.conf是

App {
    postgres {
        dbHost = ${pg_DbHost}
        dbUser = ${pg_DbUser}
        dbPassword = ${pg_DbPassword}
        dbPort = ${pg_DbPort}
   }

在src/main/resources中使用以下代码

val jobConf = ConfigFactory.load("test-app.conf")
val postgresConf : Config = jobConf.getConfig("App.postgres")

我将环境中的所有变量都导出到local上,工作正常。我在flink环境中部署了jar,但它没有加载变量
在构建flink时,我还在conf/flink-conf.yaml中指定变量。我在kubernetes集群上部署了docker映像。
从flink环境在conf文件中加载变量的方法是什么?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题