我正在尝试找出Apache Flink的关键健康指标是什么。Flink文档提供了大量的指标列表，很难找出重要的指标。
浏览 29提问于2019-02-01得票数 1
回答已采纳
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
浏览 27提问于2020-01-16得票数 0
请分享你的想法和帮助。
我已经安装了Apache通过自制，别名fstart和fstop启动/停止Flink。基于这个JMX记者linkhttps://ci.apache.org/projects/flink/flink-docs-release-1.4/monitoring/metrics.h
浏览 3提问于2018-05-26得票数 1
回答已采纳
使用flink版本1.13.1metrics.reporter.kafka.factory.class: org.apache.flink</
浏览 10提问于2021-08-25得票数 2
回答已采纳
我正在通过prometheus Flink metrics Reporter向Prometheus发送自定义应用程序指标。指标创建正确，因为我能够在flink仪表板中准确地看到它们。当我转向prometheus端点(curl http://localhost:9090/api/v1/metrics)时，我只能看到集群指标，而不能看到我正在创建的自定义指标。我怀疑这个问题与我如何配置Prometheus Flink
浏览 45提问于2021-08-06得票数 2
Flink Web UI有一个出色的背压部分。但我看不到任何指标，由普罗米修斯记者给出，可以用来检测背压的相同方式为Grafana仪表盘。 ?有没有办法在Flink Web UI之外获得相同的指标？使用此处描述的指标https://ci.apache.org/projects/flink/flink-docs-stable&#x
浏览 68提问于2019-03-13得票数 2
回答已采纳
1回答
我有以下非常简单的Apache Flink Pipeline，我想通过Apache Flink Dashboard获得一些指标，如中所述：import org.apache.flink.configuration.Configuration;
import org.apache</em
浏览 90提问于2020-03-02得票数 3
回答已采纳
我正在使用Flink 1.4.1和Beam 2.3.0，我想知道是否可以像数据流WebUI一样在Flink WebUI (或任何地方)中提供指标？我使用过计数器，比如：import org.apache.beam.sdk.metrics.Metrics;..
浏览 2提问于2018-02-28得票数 12
我知道flink有一些预定义的变量，比如<host>，我可以通过以下方式获取它:flink谢谢
浏览 14提问于2017-07-01得票数 0
回答已采纳
我正在将Flink 1.9.1集群升级到Flink 1.15.0集群。这要求我更新Flink作业代码中的Flink API。更新后的作业在Flink 1.15.0上运行良好，只是它不发出任何应用程序级别指标。然后，flink-metrics-statsd插件处理将度量发送到StatsD端点的部分。我已经确认在StatsD端点上使用tcpdump发送了系统级别的度量，但是我在代码中显式注册的度量在哪里
浏览 43提问于2022-07-19得票数 0
回答已采纳
我们有一个大约30个操作员的flink工作。当我们以12个flink的并行度运行这个作业时，总共输出400.000个指标，这对于我们的指标平台来说太多了，无法很好地处理。在查看指标类型时，这似乎不是一个bug或类似的东西。 只是当有许多操作员和许多任务管理器和任务槽时，指标的数量经常会重复，以至于达到400.000 (也许作业重新启动也会重复指标的数量？)这是我用于我们的指标的配置
浏览 22提问于2019-01-16得票数 1
1回答
指标导出器
、、、
有没有办法将每个操作员的状态或检查点大小的指标导出到Prometheus？我知道我可以从Flink Dashboard中找到这个值，但我需要在Prometheus的一个Grafana板中包含所有的指标，希望这是可能的。我希望在Grafana中的flink dashboard中有类似的东西： ? 非常感谢!
浏览 10提问于2020-08-05得票数 0
-在本地嵌入式Flink迷你集群主信息org.apache.flink.runtime.minicluster.MiniCluster上运行作业-启动Flink mini集群主信息org.apache.flink.runtime.minicluster.MiniCluster-启动度量注册表主要信息org.apache.flink.runtime.metrics.MetricRegistryImpl -没有指标报告配置，没有指
浏览 1提问于2018-11-05得票数 0
回答已采纳
我正在运行flink run-application目标Kubernetes，使用以下选项：我指定了一个容器镜像，它将普罗米修斯插件复制到/opt/flink/plugins中。从作业管理器容器中，我可以在端口9249上下载Prometheus指标</
浏览 17提问于2021-06-22得票数 0
1回答
除了这个question之外，我还创建了这个示例来集成DataStreamAPI和TableAPI，这一次我没有出错，而且我有两个作业而不是一个，一个作业是为运行正常的DataStreamAPI创建的，另一个作业是为运行正常的TableAPI创建的，但唯一的问题是永远不会从DataStreamAPI收到任何值，示例： /*FILTERING NULL IDs*/ env.e
浏览 39提问于2020-09-08得票数 0
回答已采纳
我有一个Flink保存点。我想使用API生成一份关于它的报告，最好是用Java编写。将保存点看作一个数据库，我想列出表、表模式、每个表的大小(以行和字节为单位)，并以字节为单位生成行大小的统计信息(最小、最大、平均、标准。dev.等)。here描述的API假设db模式是已知的(继续db类比)。有没有API可以做到这一点？
浏览 19提问于2021-10-06得票数 0
回答已采纳
我已经按照文档度量部分中的说明设置了PrometheusPushGatewayReporter。我可以看到来自flink作业管理器和推送网关UI中暴露的任务管理器的指标，以及它们被Prometheus集群正确抓取。问题是，即使我已经显式设置了deleteOnJobShutdown配置选项，当通过flink cli工具取消作业时，只有作业管理器的指标会被删除。 有没有办法也删除陈旧的任务管理器指标？我的</em
浏览 116提问于2019-01-29得票数 0
我在Yarn上运行Flink，我想收集一些指标来看看情况如何。: org.apache.flink.metrics.prometheus.PrometheusReporter在prometheues上，当我查询这个集群(我有4个主机)时，我得到了每个主机的单个任务管理器的指标。总共大约有30个TM，我想我会得到所有这些TM的指标。有没有一种简单的方
浏览 3提问于2021-05-13得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
