腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Flink
webUI
中
的
“
无
指标
”
java
、
apache-flink
、
metrics
、
flink-streaming
我启动了一个本地
flink
服务器(./bin/start-cluster.sh),并提交了一个作业。我有以下代码来定义自定义
指标
: .map(new RichMapFunction<String, String>() { this.counter.inc(); } }) 但是,当我运行作业并发送一些数据时,我在
fli
浏览 40
提问于2019-05-21
得票数 1
回答已采纳
3
回答
Apache波束计数器/度量在
Flink
WebUI
中
不可用
java
、
apache-flink
、
metrics
、
apache-beam
我正在使用
Flink
1.4.1和Beam 2.3.0,我想知道是否可以像数据流
WebUI
一样在
Flink
WebUI
(或任何地方)中提供
指标
?Counter elementsRead = Metrics.counter(getClass(), "elements_read");elementsRead.inc(); 但我在
Flink
WebUI
中
找不到可用
的
"elements_read&quo
浏览 2
提问于2018-02-28
得票数 12
3
回答
从IDE运行时
的
Flink
webui
apache-flink
、
flink-streaming
我想看看我在网络用户界面上
的
工作。 import org.apache.
flink
.configuration.ConfigConstants
浏览 5
提问于2017-10-28
得票数 20
回答已采纳
2
回答
我如何知道Apache运行在哪个端口上?
apache-flink
我安装了apache,转到
flink
-1.14.3文件夹并运行.bin/start-cluster.sh。Starting cluster.我怎么知道
Flink
运行在哪个端口上?我在浏览器中去了,但是那里什么都没有。
浏览 4
提问于2022-01-20
得票数 0
回答已采纳
1
回答
Apache
Flink
在UI
中
显示自定义
指标
,但prometheus metrics reporter不抓取它们
apache-flink
、
prometheus
、
metrics
我正在通过prometheus
Flink
metrics Reporter向Prometheus发送自定义应用程序
指标
。
指标
创建正确,因为我能够在
flink
仪表板
中
准确地看到它们。当我转向prometheus端点(curl http://localhost:9090/api/v1/metrics)时,我只能看到集群
指标
,而不能看到我正在创建
的
自定义
指标
。我怀疑这个问题与我如何配置Prometheus
浏览 45
提问于2021-08-06
得票数 2
2
回答
Apache集合环境变量
scala
、
apache-flink
我正在使用
flink
-docker 1.4.0,我已经创建了一个scala作业以在
Flink
上运行。KAFKA_SERVERS} 问题是,如果我在启动作业管理器和任务管理器
的
坞-复合文件
中
设置了KAFKA_SERVERS,那么它就能很好地工作。但是我想用程序参数从
WebUI
中
设置它们。我试图添加env.java.opts="-DKAFKA_SERVERS=192.168.99.100:9092,就像在.But中一样,它在jar
中
是不可见
的
。是
浏览 0
提问于2018-03-09
得票数 1
回答已采纳
1
回答
Flink
运行时如何获取任务管理器JVM
指标
,如“Status.JVM.Memory.Heap.Used”?
java
、
apache-flink
、
flink-streaming
有一些博客文章介绍了
Flink
指标
报告系统
的
高级设计。然而,我仍然不清楚像“Status.JVM.Memory.Heap.Used”这样
的
与JVM相关
的
指标
是如何收集
的
。我试着在
Flink
源代码中找到它。MemoryLogger.java似乎在获取JVM相关
指标
方面做了一些工作。https://github.com/apache/
flink
/blob/mas
浏览 27
提问于2020-01-16
得票数 0
1
回答
apache
flink
DataSet窗口聚合
apache-flink
我使用cassandra来读取大量文件并将它们放入DataSet
中
。 在其中一个步骤
中
,我执行了大量HTTP请求,我想知道每秒我发送了多少个请求。使用Stream API,使用滑动窗口非常简单,但是如何使用DataSet API来做同样
的
事情呢?
浏览 0
提问于2016-10-23
得票数 0
1
回答
指向Azure存储
的
Azure
Flink
检查:找不到帐户
的
凭据
azure
、
storage
、
apache-flink
、
azure-aks
我尝试在连接到Azure Storage
的
Azure Kubernetes上运行一个测试
Flink
应用程序。在我
的
Flink
应用程序
中
,我配置了以下配置: Configuration cfg = new Configuration(); cfg.setString("fs.azure.account.key.当我将应用程序部署到Kubernetes时,JobManager会运行并在Azure Storage容器
中
创建检查点文件夹,然而,Block blob数据
的</em
浏览 102
提问于2021-10-22
得票数 0
回答已采纳
1
回答
Apache
Flink
的
关键运行状况
指标
monitoring
、
apache-flink
我正在尝试找出Apache
Flink
的
关键健康
指标
是什么。
Flink
文档提供了大量
的
指标
列表,很难找出重要
的
指标
。
浏览 29
提问于2019-02-01
得票数 1
回答已采纳
2
回答
Flink
metrics -
指标
间隔内计数
的
记录数
apache-flink
、
flink-streaming
我们使用
的
是
Flink
版本1.9.1。我们想要获取特定子任务在特定时间段内处理
的
记录数。输出记录
的
数量给出了到那时为止输出
的
记录总数。有没有办法获得在该度量间隔内处理
的
记录总数。
浏览 35
提问于2020-08-17
得票数 0
1
回答
Windows 11和Apache
Flink
部署
windows
、
apache-flink
我正试图在我
的
Windows 11计算机上运行本地
Flink
集群。我按照推荐文档
的
步骤安装了Java和Cygwin。
Flink
似乎从start-cluster.sh脚本开始很好,但是我无法连接到
WebUI
。在Windows上部署
Flink
v1.14.3
的
推荐方法是什么?
浏览 1
提问于2022-01-26
得票数 0
1
回答
如何使用Prometheus
指标
监控Grafana
中
的
Flink
Backpressure
apache-flink
、
grafana
、
prometheus
、
flink-streaming
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
、
metrics
、
stateful
大家好,最近开始使用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
1.7.0仪表板未显示任务统计信息
docker
、
kubernetes
、
apache-flink
、
flink-streaming
我使用
Flink
1.7仪表板并选择一个流作业。这应该会向我显示一些
指标
,但它仍然需要加载。 我可以做这项工作,删除docker-compose.yaml文件
中
的
主机
浏览 4
提问于2019-04-24
得票数 1
1
回答
如何让pod在Kubernetes上以
Flink
应用模式暴露prometheus监控端口?
kubernetes
、
apache-flink
、
prometheus
我正在运行
flink
run-application目标Kubernetes,使用以下选项:我指定了一个容器镜像,它将普罗米修斯插件复制到/opt/
flink
/plugins
中
。从作业管理器容器
中
,我可以在端口9249上下载Prometheu
浏览 17
提问于2021-06-22
得票数 0
1
回答
Hpw将在本地Jconsole JMX控制台上用JMX报告器显示
Flink
指标
jboss
、
yaml
、
wildfly
、
jmx
、
apache-flink
请分享你
的
想法和帮助。 metrics.reporters: jmx metrics.reporter.jmx.class: org.apache.
flink
.metrics.jmx.JMXReporter我选了"or
浏览 3
提问于2018-05-26
得票数 1
回答已采纳
1
回答
Flink
Prometheus Push Gateway Reporter -作业关闭时删除
指标
hadoop
、
apache-flink
、
hadoop-yarn
、
prometheus
、
prometheus-pushgateway
我已经按照文档度量部分
中
的
说明设置了PrometheusPushGatewayReporter。我可以看到来自
flink
作业管理器和推送网关UI
中
暴露
的
任务管理器
的
指标
,以及它们被Prometheus集群正确抓取。问题是,即使我已经显式设置了deleteOnJobShutdown配置选项,当通过
flink
cli工具取消作业时,只有作业管理器
的
指标
会被删除。 有没有办法也删除陈旧
的
任务管理器
浏览 116
提问于2019-01-29
得票数 0
1
回答
为什么
Flink
使用Pushgateway而不是Prometheus通常
的
一般度量集合拉模型?
apache-flink
、
flink-streaming
、
prometheus-pushgateway
我们可以看到,在将
Flink
度量暴露于外部系统(如Prometheus )时,
Flink
使用Pushgateway而不是Prometheus通常
的
拉模型进行一般度量集合。", jobName, e);} 然而,从Prometheus下面的官方文档
中
可以看出,"Prometheus直接或通过中间推送网关为短寿命作业从工具作业
中
收集
指标
“,显然
Flink
流作业不是短暂
的
工作,那么为什么
Flink
使用Pu
浏览 2
提问于2018-08-19
得票数 0
回答已采纳
1
回答
如何在Apache
Flink
ui
中
显示
指标
?
java
、
apache-flink
运行Apache
Flink
1.8.0。我可以在http://localhost:8081上访问工作
的
UI。我还验证了我
的
工作可以在集成开发环境
中
工作,使用./
flink
run通过命令行提交。但当我查看UI上
的
统计数据时,我只看到一个微调器。例如:字节接收,接收
的
记录,发送
的
字节,发送
的
记录都有一个微调。我也在我
的
RichAsyncFunction里做了 UI
的
文档
浏览 32
提问于2019-05-04
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink基础教程(三):生产环境中的Flink
关于Flink中的时间概念
Flink在AI流程中的应用
flink和spark Streaming中的Back Pressure
Flink 中的应用部署:当前状态与新应用模式
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券