flink-adding工具

ccrfmcuu 于 2021-06-24 发布在 Flink

关注(0)|答案(2)|浏览(332)

我想在我的flink工作中加入newrelic仪器。我看不出在哪里可以将额外的类路径/其他参数传递给 bin/flink run <job> 命令。
newrelic java代理想要 -javaagent:<path to jar> 添加到执行路径。传入配置文件路径也是可取的。

我在所有（3）台集群计算机上的conf/flink-conf.yaml中添加了这一行：

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

当我启动集群时，只有作业管理器会启动。任务管理器不会在任何机器上启动。
我发现添加插装（到目前为止）的唯一方法是更改bin/flink末尾的命令行以包含上述参数。这很好，只是它需要运行命令的会话保持打开状态。如果你退出，Flink的工作继续进行，但纽雷特工退出。

2条答案

您可以通过 env.java.opts 可以在flink的配置文件中设置的配置值 flink-conf.yaml .

首先删除值中的引号（右侧）

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

还要确保将文件放在flink的“lib”目录中，并将命令重写为

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

“lib”目录中的所有文件都将复制到作业管理器和任务管理器中，并在相对路径中可用。“/lib”