Параметры Typesafe-Config JVM не могут быть получены в Flink

Существует проект Flink, использующий типизированный конфиг, когда я пытался запустить проект в отдельном кластере с помощью команды flink run xxxx.jar -Dconfig=XXXX -Dus=XXXX...Я обнаружил, что параметры JVM (здесь config и мы) не могут быть распознаны правильно. Обычно он должен заменить значение соответствующего ключа в application.conf с ценностью XXXX,

Источник

1 ответ

Использование

ParameterTool parameter = ParameterTool.fromSystemProperties();

чтобы получить доступ к вашему config а также us параметры.

Получение значений вашей конфигурации в ParameterTool:

https://ci.apache.org/projects/flink/flink-docs-master/dev/best_practices.html

Источник
Другие вопросы по тегам