我正在通过prometheus Flink metrics Reporter向Prometheus发送自定义应用程序指标。指标创建正确，因为我能够在flink仪表板中准确地看到它们。当我转向prometheus端点(curl http://localhost:9090/api/v1/metrics)时，我只能看到集群指标，而不能看到我正在创建的自定义指标。我怀疑这个问题与我如何配置Pr
浏览 45提问于2021-08-06得票数 2
我知道flink收集开箱即用的延迟指标，但我想知道如何获得我工作的延迟数据。谢谢。
顺便说一下，我正在使用Flink V1.2.1。
浏览 15提问于2017-07-20得票数 2
回答已采纳
1回答
在Apache Flink中存在4种类型的指标。目标是向直方图度量中添加额外的信息:例如user_id和speed_of_processing： user_id: speed_of_processing
2:15 sec ..。如何添加此类信息？
浏览 28提问于2021-09-27得票数 0
回答已采纳
1回答
大家好，最近开始使用Apache Flink Stateful functions。我们正在使用Flink reporter将指标放入InfluxDB https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/metric_reporters/有状态函数提供了具有几个开箱即用指标的"function“作用域
浏览 34提问于2021-11-04得票数 1
回答已采纳
1回答
我启动了一个本地flink服务器(./bin/start-cluster.sh)，并提交了一个作业。我有以下代码来定义自定义指标： .map(new RichMapFunction<String, String>() { this.counter.inc(); }
}) 但是，当我运行作业并发送一些
浏览 40提问于2019-05-21得票数 1
回答已采纳
我有一个Flink保存点。我想使用API生成一份关于它的报告，最好是用Java编写。将保存点看作一个数据库，我想列出表、表模式、每个表的大小(以行和字节为单位)，并以字节为单位生成行大小的统计信息(最小、最大、平均、标准。dev.等)。
浏览 19提问于2021-10-06得票数 0
回答已采纳
1回答
，我有一个使用flink (1.9)的程序，我想在仪表板的帮助下检查Map实例的吞吐量。从现有的指标来看，numRecordsInPerSecond似乎是最有希望的，但我想它不涉及处理时间。的另一个想法是在map函数的末尾添加一个米，但是我认为如果源生成记录的速度不够快，计算出的吞吐量就会更糟，因为运算符大部分时间都处于空闲状态。对吗？
请具体回答1和2。
浏览 1提问于2020-09-10得票数 0
回答已采纳
我有一个Flink应用程序部署在AWS动态数据分析。我目前的设置是：Parallelism per KPU=4从Flink UI：计数：从Cloudwatch：计数：
NumRecordsOut：
这两项指标都接近1 080万。FWIW，我添加了一个跟踪
浏览 22提问于2022-03-26得票数 1
2回答
我有一个带有独立模式的Apache Flink集群，我想配置Flink Metrics。flink-conf.yaml中的配置 metrics.reporters: my_jmx_reporter,my_other_reporter
metrics.reporter.my_other_reporter.host: 10.0.0.203metr
浏览 31提问于2019-01-17得票数 1
回答已采纳
我们使用的是Flink版本1.9.1。我们想要获取特定子任务在特定时间段内处理的记录数。输出记录的数量给出了到那时为止输出的记录总数。有没有办法获得在该度量间隔内处理的记录总数。
浏览 35提问于2020-08-17得票数 0
我设置了一个Flink工作，向Kafka主题写一些消息。它使用FlinkKafakProducer作为接收器。我验证了输出Kafka主题中写入了消息，但Flink指标numRecordsOut始终显示0。同样，在Flink Web UI中，发送的字节也始终显示0B。
浏览 20提问于2019-03-28得票数 1
回答已采纳
1回答
我需要从Flink 1.10导出自定义度量到Prometheus。我已经创建并使用了我的自定义度量标准，但问题是，当我打印出来(例如在终端中)以查看指标时，很多度量都来自Flink，而我不需要它们，比如: flink_taskmanager_job_task_Shuffle_Netty_Input_Buffers_inputQueueLength我只是对从Flink我的自定义度量到Prometheus的扩展感兴趣，然后删除其中的其他指标</em
浏览 1提问于2020-06-05得票数 0
回答已采纳
我需要知道在我的flink程序中实现自定义指标的方法。目前，我知道我们可以在RuntimeContext的帮助下创建自定义指标。但是在我的aggregate()中，我没有RuntimeContext。那么，请指导我，如何在我的代码中创建自定义指标？
注意:正如我们所知，我们不能使用RichAggregateFunction ()方法
浏览 2提问于2018-12-18得票数 1
1回答
我是Flink社区的新手，我正在尝试做一项实验研究，以捕获Flink对流数据的性能。为此，我尝试收集几个小时内正在运行的作业的统计数据。但是，使用Flink的UI，我只能看到过去5分钟的统计数据。我尝试访问Rest API，但它不包含除读取/写入字节以外的统计数据。
任务指标下的UI中提供的指标非常有用，但扩展时间不能超过5分钟。有没有一种方法可以捕获指标的整个历史。
浏览 3提问于2017-11-15得票数 0
我试图从JMX控制台看到JMX记者的flink指标。步骤：
我已经安装了Apache通过自制，别名fstart和fstop启动/停止Flink。基于这个JMX记者linkhttps://ci.apache.org/projects/flink/flink-docs-release-1.4/monitoring/metrics.html#jmx-orgapacheflinkmetricsjmxjmxreporter](])，
浏览 3提问于2018-05-26得票数 1
回答已采纳
我正在运行一个Flink应用程序，作为 Analytics服务的一部分。Flink构建了对度量的支持，我有一个简单的计数器设置，我可以看到它正在工作，它可以在flink仪表板中使用。现在，我想将石墨配置为用于收集我的指标。根据Flink，这是可能的：与java代码一起创建文件conf/flink-conf.java的ignored.Passing ，但它在配置覆盖StreamExecutionEnv
浏览 2提问于2022-01-25得票数 1
在Flink中，我使用Python在FlatMapFunction中生成自定义度量。[{"id":"0.FlatMap.my_counter_sum","value":"28201"}]metrics.scope.jm: flink.jobmanager
metrics.scope.jm.job:
浏览 16提问于2022-11-16得票数 0
使用flink版本1.13.12021-08-25 14:54:06,243 WARN org.apache.flink.runtime.metrics.ReporterSetup但我已经在plugins文件夹中创建了名为“指标-kafka”的文件夹，而不是打包度量报告，并将jar文件复制到“指标-kafka”或lib文件夹(这两个文件夹都不
浏览 10提问于2021-08-25得票数 2
回答已采纳
我正在使用Flink 1.4.1和Beam 2.3.0，我想知道是否可以像数据流WebUI一样在Flink WebUI (或任何地方)中提供指标？Counter elementsRead = Metrics.counter(getClass(), "elements_read");elementsRead.inc();
但我在FlinkWebUI中找不到可用的"elements_read"计数(任务指标或累加器)。
浏览 2提问于2018-02-28得票数 12
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
