2回答
我已经为在Intellij IDEA中运行的应用程序设置了Flink UI。我想获得一些流指标，如-调度延迟和处理时间。但是，我在UI中找不到anywhere。应该有一些具体的设置，或者我应该显式地提交app jar？ 目前，该作业的Flink UI如下所示： ?
浏览 25提问于2020-01-21得票数 0
回答已采纳
我正在通过prometheus Flink metrics Reporter向Prometheus发送自定义应用程序指标。指标创建正确，因为我能够在flink仪表板中准确地看到它们。当我转向prometheus端点(curl http://localhost:9090/api/v1/metrics)时，我只能看到集群指标，而不能看到我正在创建的自定义指标。我怀疑这个问题与我如何配置Prometheus
浏览 45提问于2021-08-06得票数 2
我正在尝试在Flink应用程序中暴露一个普罗米修斯仪表： @transient def metricGroup: MetricGroup = getRuntimeContext.getMetricGroup() => gaugeValue)) } catch { }
} 该应用程序在本地运行良好，并且公开指标没有任何问题。为什么本地app会暴露指标，而在集群上注册
浏览 21提问于2020-06-14得票数 2
有一些博客文章介绍了Flink指标报告系统的高级设计。然而，我仍然不清楚像“Status.JVM.Memory.Heap.Used”这样的与JVM相关的指标是如何收集的。我试着在Flink源代码中找到它。MemoryLogger.java似乎在获取JVM相关指标方面做了一些工作。https://github.com/apache/flink/blob/mas
浏览 27提问于2020-01-16得票数 0
我正在尝试找出Apache Flink的关键健康指标是什么。Flink文档提供了大量的指标列表，很难找出重要的指标。
浏览 29提问于2019-02-01得票数 1
回答已采纳
我们使用的是Flink版本1.9.1。我们想要获取特定子任务在特定时间段内处理的记录数。输出记录的数量给出了到那时为止输出的记录总数。有没有办法获得在该度量间隔内处理的记录总数。
浏览 35提问于2020-08-17得票数 0
Flink Web UI有一个出色的背压部分。但我看不到任何指标，由普罗米修斯记者给出，可以用来检测背压的相同方式为Grafana仪表盘。 ?有没有办法在Flink Web UI之外获得相同的指标？使用此处描述的指标https://ci.apache.org/projects/flink/flink-docs-stable/monito
浏览 68提问于2019-03-13得票数 2
回答已采纳
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
回答已采纳
参考在线python编程指南：，我没有看到任何与流媒体编程相关的材料，比如kafka连接器等等。
同样在git hub示例()中，我也没有看到python代码。
浏览 16提问于2017-08-11得票数 2
回答已采纳
1回答
理想情况下，我想运行一些实验来测量我的应用程序的输入使用者的压力(即，如果我的应用程序落后于输入数据主题，并且消息到达的速度快于它们的处理速度)。有人告诉我这很常见，但我不知道该怎么做 我正在阅读1.9版本的Metrics文档，从我得到的内容来看，我必须配置conf/flink-conf.yaml (在独立模式下)，假设jmx报告器是这样的： metrics.report
浏览 51提问于2020-06-15得票数 0
我想在Apache Flink中做流式作业，在Apache Flink(Scala)中做Kafka -> Flink -> HIVE。谁能给代码样本，因为他们的官方文件不是很清楚。
浏览 11提问于2020-07-09得票数 1
回答已采纳
我的Flink服务器在8081端口本地运行。我在上面部署了flink应用程序的jar，它成功地运行了。现在，我需要听取prometheus的Flink指标，为此，我需要在prometheus.yml中将作业管理器和任务管理器配置为目标。
那么，在哪里可以获得相同的端口呢？
浏览 0提问于2020-07-03得票数 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
回答已采纳
请分享你的想法和帮助。
metrics.reporters: jmx metrics.reporter.jmx.class: org.apache.flink.metrics.jmx.JMXReporter我选了"or
浏览 3提问于2018-05-26得票数 1
回答已采纳
我正在运行一个Flink应用程序，作为 Analytics服务的一部分。Flink构建了对度量的支持，我有一个简单的计数器设置，我可以看到它正在工作，它可以在flink仪表板中使用。现在，我想将石墨配置为用于收集我的指标。根据Flink，这是可能的：与java代码一起
浏览 2提问于2022-01-25得票数 1
1回答
我们如何实时监控flink作业。例如，如果作业失败，则会生成一些警报。是否存在任何外部库，或者flink中已有可用的库。提前谢谢。
浏览 14提问于2021-06-02得票数 1
目前，我正在尝试使用Apache Flink处理ETL。在项目中，有几个步骤需要查询维度表才能将CityName转换为CityID。map to CityId) ---- Employee ETL (CityName column map to CityId)
目前，对于每个流，我们方法是在维度表所在的MySQL这不是一个有效的方法，我想问一下，有没有一种方法可以在Flink内部保留维度表内容，并能够在整个项目范围内使用。
浏览 4提问于2017-05-11得票数 0
在使用Flink 1.55及其表API的流式应用程序中，我需要检测和处理延迟元素。我找不到替代DataStream应用编程接口.sideOutputLateData(...)的功能。我试着在Flink文档、https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/table/tableApi.html和谷
浏览 36提问于2019-06-19得票数 2
1回答
我使用Flink 1.7仪表板并选择一个流作业。这应该会向我显示一些指标，但它仍然需要加载。
我可以做这项工作，删除docker-compose.yaml文件中的主机名services:
浏览 4提问于2019-04-24得票数 1
云服务器
ICP备案
实时音视频
云直播
对象存储
腾讯云开发者
