问题描述
我一直在尝试在 Apache Flink 的工作中使用 OpenTelemetry (https://opentelemetry.io/)。我将跟踪发送到 Kafka 主题，以便在 Jaeger 中查看它。
当我在我的 IntelliJ IDE 中执行它时，可追溯性在工作中起作用，但是一旦我创建了包并尝试在集群中执行它，我就无法让它工作。 Apache Flink 是否有任何我不知道的拦截器？
我使用一个变量完成了这个：
export FLINK_ENV_JAVA_OPTS=-javaagent:./lib/opentelemetry-javaagent-all.jar
但是如果我正在设置 Flink 的集群，这会起作用。问题是我使用的集群在 AWS (Kinesis Analytics) 内部，我无法设置这个变量。
有没有办法在 Flink 中使用 OpenTelemetry？
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）