如何解决将 OpenTelemetry 与 Apache Flink 结合使用
我一直在尝试在 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 举报，一经查实，本站将立刻删除。
