Scala файл application.conf не загружает переменную из среды flink - PullRequest
0 голосов
/ 12 марта 2020

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

Я экспортирую все переменные в среда на местном и работает нормально. Я развернул jar в среде Flink, но он не загружает переменную

Я также указываю переменную в conf / flink-conf.yaml при сборке flink. Я развернул образ docker в кластере Kubernetes.

Как загрузить переменную в файл conf из среды flink?

...