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文件中加载变量的方法是什么?
暂无答案!
目前还没有任何答案,快来回答吧!