Flink - добавление инструментария

Я хочу добавить инструменты NewRelic к моим работам на флинге. Я не вижу, где можно передать дополнительные параметры classpath/other params в команду bin/flink run.

Агент Java NewRelic хочет добавить -javaagent: к пути выполнения. Также рекомендуется пропустить путь к файлу конфигурации.

Изменить:

Я добавил эту строку в свой conf/flink-conf.yaml на всех (3) кластерных машинах:

env.java.opts: "-javaagent:/opt/newrelic/newrelic.jar -Dnewrelic.config.file=/opt/newrelic/newrelic.yml"

Когда я запустил кластер, запустится только менеджер job manager. Диспетчер не запускается ни на одной из машин.

Единственный способ, с помощью которого я смог добавить инструментарий (пока), - изменить командную строку в конце bin/flink, чтобы включить указанные выше параметры. Это прекрасно, за исключением того, что для этого требуется сеанс, в котором команда была запущена, чтобы оставаться открытой. Если вы выходите, работа Flink продолжается, но агент NewRelic завершает работу.

2 ответа

Вы можете передать дополнительные параметры запуска JVM с помощью значения конфигурации env.java.opts, которое вы можете установить в файле конфигурации Flink flink-conf.yaml.


Сначала удалите кавычки в значении (справа)

env.java.opts: -javaagent:/opt/newrelic/newrelic.jar -Dnewrelic.config.file=/opt/newrelic/newrelic.yml

А также убедитесь, что вы поместили файлы в каталог "lib" flink и перепишите команду как

env.java.opts: -javaagent:lib/newrelic.jar -Dnewrelic.config.file=lib/newrelic.yml

Все файлы в каталоге "lib" будут скопированы в диспетчер заданий и диспетчеров задач и доступны по относительному пути "./lib"

licensed under cc by-sa 3.0 with attribution.