Я использую автономный кластер Flink, состоящий из 3 серверов. Я добавил "env.java.opts: '-Dmykey = 1000'" для этих 3-х узлов, в этом файле flink-1.6.0 / conf / flink-conf.yaml
Когда я проверяю Java-программы, я вижу, как этот параметр передается в мой TaskManager и JobManager
/usr/lib/jvm/java-8-oracle/bin/java -Xms15360M -Xmx15360M -XX:MaxDirectMemorySize=8388607T -Dmykey=1000 -Dlog.file=/home/kafka/flink-1.6.0/log/flink-
Когда я пытаюсь распечатать все свойства, повторяя System.getProperties (), я не могу получить свои пользовательские свойства.
У меня есть библиотеки, которые используют файлы свойств для получения внешней информации, я не могу изменить свои библиотеки, заставить их использовать ParameterTools. Я много чего делал, но так и не смог решить. Есть какой-нибудь совет для меня?