1回答
我有以下非常简单的Apache Flink Pipeline，我想通过Apache Flink Dashboard获得一些指标，如中所述：import org.apache.flink.configuration.Configuration;
import org.apache.fli
浏览 90提问于2020-03-02得票数 3
回答已采纳
我正在通过prometheus Flink metrics Reporter向Prometheus发送自定义应用程序指标。指标创建正确，因为我能够在flink仪表板中准确地看到它们。我怀疑这个问题与我如何配置Prometheus Flink Metrics Reporter有关，因为当我尝试访问http://localhost:9090时，没有UI，只有上面提到的集群指标列表。创建指标的flink工作代码(在<em
浏览 45提问于2021-08-06得票数 2
我正在运行flink run-application目标Kubernetes，使用以下选项：我指定了一个容器镜像，它将普罗米修斯插件复制到/opt/flink/plugins中。从作业管理器容器中，我可以在端口9249上下载Prometheus指标</
浏览 17提问于2021-06-22得票数 0
我试图从JMX控制台看到JMX记者的flink指标。步骤：
我已经安装了Apache通过自制，别名fstart和fstop启动/停止Flink。基于这个JMX记者linkhttps://ci.apache.org/projects/flink/flink-docs-release-1.4/monitoring/metrics.html#jmx-orgapacheflinkmetricsj
浏览 3提问于2018-05-26得票数 1
回答已采纳
我正在创建一个使用apache处理数百万条记录的流程，以支持物流数据管道。我正在从动力源/沉源移到卡夫卡源/沉源。作业不更新度量图
浏览 6提问于2022-08-03得票数 0
1回答
我启动了一个本地flink服务器(./bin/start-cluster.sh)，并提交了一个作业。我有以下代码来定义自定义指标： .map(new RichMapFunction<String, String>() { this.counter.inc(); }
}) 但是，当我运行作业并发送一些数据时，我在fli
浏览 40提问于2019-05-21得票数 1
回答已采纳
1回答
我使用Flink 1.7仪表板并选择一个流作业。这应该会向我显示一些指标，但它仍然需要加载。
我可以做这项工作，删除docker-compose.yaml文件中的主机名services:
浏览 4提问于2019-04-24得票数 1
启动flink时，JobManager显示警告日志，如下所示：
2021-08-25 14:54:06,243 WARN org.apache.flink.runtime.metrics.ReporterSetup, org.apache.flink.metrics.jmx.JMXReporterFactory, org.apache.flink.metrics.influxdb.InfluxdbReporterFactory但我已经在plugins
浏览 10提问于2021-08-25得票数 2
回答已采纳
1回答
大家好，最近开始使用Apache Flink Stateful functions。我们正在使用Flink reporter将指标放入InfluxDB https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/metric_reporters/有状态函数提供了具有几个开箱即用指标的
浏览 34提问于2021-11-04得票数 1
回答已采纳
有一些博客文章介绍了Flink指标报告系统的高级设计。然而，我仍然不清楚像“Status.JVM.Memory.Heap.Used”这样的与JVM相关的指标是如何收集的。我试着在Flink源代码中找到它。MemoryLogger.java似乎在获取JVM相关指标方面做了一些工作。https://github.com/apache/flink/blob/master/flink-run
浏览 27提问于2020-01-16得票数 0
我正在尝试找出Apache Flink的关键健康指标是什么。Flink文档提供了大量的指标列表，很难找出重要的指标。
浏览 29提问于2019-02-01得票数 1
回答已采纳
我知道flink收集开箱即用的延迟指标，但我想知道如何获得我工作的延迟数据。谢谢。
顺便说一下，我正在使用Flink V1.2.1。
浏览 15提问于2017-07-20得票数 2
回答已采纳
我将Apache配置为通过conf/flink-conf.yaml文件向Prometheus发送指标： - targets: ['jobmanager:9250', 'taskmanager1:9251', 'taskmanager2:92
浏览 2提问于2019-03-29得票数 1
回答已采纳
2回答
我已经为在Intellij IDEA中运行的应用程序设置了Flink UI。我想获得一些流指标，如-调度延迟和处理时间。但是，我在UI中找不到anywhere。目前，该作业的Flink UI如下所示： ?
浏览 25提问于2020-01-21得票数 0
回答已采纳
Flink Web UI有一个出色的背压部分。但我看不到任何指标，由普罗米修斯记者给出，可以用来检测背压的相同方式为Grafana仪表盘。 ?有没有办法在Flink Web UI之外获得相同的指标？使用此处描述的指标https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html。
浏览 68提问于2019-03-13得票数 2
回答已采纳
我已经编写了flink作业来使用数据集和数据流api。我已经从相同的main()方法启动了这两个程序，但现在当我将作业提交到flink Dashboard时。只有dataset api程序正在运行，仪表板显示作业已完成，流未被触发，flink仪表板也未显示有关数据流执行的任何内容。但是，当我从eclipse运行时，数据集和数据流api程序都在运行。是否有其他方法可以将作业提交给flink作业管理器以同时完成这两项工作？
浏览 16提问于2017-07-12得票数 1
如何在仪表板上的flink web ui中看到双值？也许，通过某种配置是可能的？
具有Flink配置的文件：如果要运行项目，只需在项目目录sbt pipeline/runLocal中使用命令即可。如果这在Flink Web中是不可能的，那么在哪里是可能的呢？(也许在Grafana?)
浏览 5提问于2021-08-17得票数 1
回答已采纳
我们开始使用Apache进行数据流处理。它处理数据，然后更新接收器中的数据库。我们将数据库端点/凭据配置为Flink配置数据(因为我们有标准dev/test/prod设置)，但不幸的是，密码/api-键与所有其他配置数据一起以明文形式显示在Flink配置仪表板中。是否有一种配置flink的方法，以便java代码仍然可以通过 (或类似的)访问敏感密码信息，但敏感数据不会显示在Flink仪表板中？
浏览 0提问于2019-09-10得票数 2
1回答
Init.init(stream_filtered);
env.execute(job_name); 通过这样做，我可以在记录器中看到下面这一行： INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
浏览 39提问于2020-09-08得票数 0
回答已采纳
我正在使用Flink 1.4.1和Beam 2.3.0，我想知道是否可以像数据流WebUI一样在Flink WebUI (或任何地方)中提供指标？我使用过计数器，比如：import org.apache.beam.sdk.metrics.Metrics;..
浏览 2提问于2018-02-28得票数 12
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
