腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如
何在
Flink
中
创建
动态
指标
、
我想
创建
一个与错误数量相关的度量标准,但实际上我想添加一些上下文标签?做到这一点的最好方法是什么?仪表盘?如
何在
任务运行过程
中
动态
创建
这种
指标
(因为open方法太早是不可能的)?提前感谢 大卫
浏览 19
提问于2019-06-21
得票数 0
1
回答
Apache
Flink
在UI
中
显示自定义
指标
,但prometheus metrics reporter不抓取它们
、
、
我正在通过prometheus
Flink
metrics Reporter向Prometheus发送自定义应用程序
指标
。
指标
创建
正确,因为我能够在
flink
仪表板
中
准确地看到它们。当我转向prometheus端点(curl http://localhost:9090/api/v1/metrics)时,我只能看到集群
指标
,而不能看到我正在
创建
的自定义
指标
。我怀疑这个问题与我如何配置Pr
浏览 45
提问于2021-08-06
得票数 2
1
回答
为什么
Flink
使用Pushgateway而不是Prometheus通常的一般度量集合拉模型?
、
、
我们可以看到,在将
Flink
度量暴露于外部系统(
如
Prometheus )时,
Flink
使用Pushgateway而不是Prometheus通常的拉模型进行一般度量集合。", jobName, e);} 然而,从Prometheus下面的官方文档
中
可以看出,"Prometheus直接或通过中间推送网关为短寿命作业从工具作业
中
收集
指标
“,显然
Flink
流作业不是短暂的工作,那么为什么
Flink
使用Pushgateway
浏览 2
提问于2018-08-19
得票数 0
回答已采纳
1
回答
我需要一种方法来编写我的
flink
程序自定义
指标
、
我需要知道在我的
flink
程序
中
实现自定义
指标
的方法。目前,我知道我们可以在RuntimeContext的帮助下
创建
自定义
指标
。但是在我的aggregate()
中
,我没有RuntimeContext。我在aggregate()方法
中
传递AggregateFunction。 那么,请指导我,如
何在
我的代码
中
创建
自定义
指标
?
浏览 2
提问于2018-12-18
得票数 1
2
回答
Flink
应用程序的流式
指标
、
、
我已经为在Intellij IDEA
中
运行的应用程序设置了
Flink
UI。我想获得一些流
指标
,
如
-调度延迟和处理时间。但是,我在UI
中
找不到anywhere。目前,该作业的
Flink
UI如下所示: ?
浏览 25
提问于2020-01-21
得票数 0
回答已采纳
1
回答
Apache
Flink
仪表板未显示
指标
、
、
我有以下非常简单的Apache
Flink
Pipeline,我想通过Apache
Flink
Dashboard获得一些
指标
,
如
中所述:import org.apache.
flink
.configuration.Configuration;importorg.a
浏览 90
提问于2020-03-02
得票数 3
回答已采纳
1
回答
用Kafka和Pandas在Python上的
Flink
不会让它下沉
、
、
、
我使用
Flink
1.11 (通过Python和Anaconda虚拟环境),并将Kafka作为我的源和接收器。我将我的
Flink
作业提交到一个集群
中
。所有的一切都是在码头(当地)进行的。DataTypes.STRING()])查看
Flink
web界面
中
的作业显示,此接收器任务正在接收数据,但没
浏览 3
提问于2020-08-28
得票数 0
1
回答
Flink
Metrics Web UI不显示双值
、
、
、
如
何在
仪表板上的
flink
web ui中看到双值?也许,通过某种配置是可能的? 具有
Flink
配置的文件:如果要运行项目,只需在项目目录sbt pipeline/runLocal中使用命令即可。如果这在
Flink
Web
中
是不可能的,那么在哪里是可能的呢?(也许在Grafana?)
浏览 5
提问于2021-08-17
得票数 1
回答已采纳
1
回答
如何使用Prometheus
指标
监控Grafana
中
的
Flink
Backpressure
、
、
、
Flink
Web UI有一个出色的背压部分。但我看不到任何
指标
,由普罗米修斯记者给出,可以用来检测背压的相同方式为Grafana仪表盘。 ?有没有办法在
Flink
Web UI之外获得相同的
指标
?使用此处描述的
指标
https://ci.apache.org/projects/
flink
/
flink
-docs-stable/monitoring/metrics.html。
浏览 68
提问于2019-03-13
得票数 2
回答已采纳
1
回答
如
何在
Apache
中
重写配置值?
、
、
我正在尝试从Apache收集
指标
到Prometheus。
Flink
文档说,我需要在我的
flink
- that . says
中
添加以下几行: metrics.reporter.promgateway.class: org.apache.
flink
.metrics.prometheus.PrometheusPushGatewayReporter如
何在
每个作业的基础上重写配置参数metrics.reporter.promgateway.jobName (每个作业都在自己的
Flink</
浏览 0
提问于2018-11-19
得票数 3
回答已采纳
1
回答
我的自定义
flink
度量报告不工作
、
使用
flink
版本1.13.12021-08-25 14:54:06,243 WARN org.apache.
flink
.runtime.metrics.ReporterSetup但我已经在plugins文件夹
中
创建
了名为“
指标
-kafka”的文件夹,而不是打包度量报告,并将jar文件复制到“
指标
-kafk
浏览 10
提问于2021-08-25
得票数 2
回答已采纳
3
回答
Apache :如何为
动态
表启用“向上插入模式”?
、
、
在
Flink
文档和官方
Flink
博客
中
,我看到了几次提到
动态
表的“向上插入模式”的情况。但是,我没有看到任何关于如
何在
动态
表上启用此模式的示例/文档。示例: 当通过update模式在流上定义
动态
表时,我们可以在表上指定一个唯一的键属性。在这种情况下,对key属性执行更新和删除操作。更新模式如下图所示。: 如
何在
Flink</em
浏览 3
提问于2018-02-01
得票数 5
回答已采纳
1
回答
自定义
Flink
- Prometheus度量标准
、
、
、
、
我需要从
Flink
1.10导出自定义度量到Prometheus。我已经
创建
并使用了我的自定义度量标准,但问题是,当我打印出来(例如在终端
中
)以查看
指标
时,很多度量都来自
Flink
,而我不需要它们,比如:
flink
_taskmanager_job_task_Shuffle_Netty_Input_Buffers_inputQueueLength我只是对从
Flink
我的自定义度量到Prometheus的扩展感兴趣,然后删除其中的其他
指标
。那么,问题是:
浏览 1
提问于2020-06-05
得票数 0
回答已采纳
2
回答
无法看到
flink
自定义
指标
到Prometheus
、
、
、
我有一个用scala编写的
flink
作业,我正在
创建
一个自定义度量来计算流
中
事件的nmber。任务部署在kubernetes上,我看到prometheus
中
作业经理和任务经理的系统度量。190:6122_3b582c",} 0.0# TY
浏览 18
提问于2022-11-10
得票数 0
回答已采纳
1
回答
如
何在
Flink
程序
中
打印kafka主题数据?
、
、
我通过下面的说明
创建
了一个主题: try{ StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment-在本地嵌入式
Flink
迷你集群主信息org.apache.
flink
.runtime.minicluster.MiniCluster上运行作业-启动
Flink<
浏览 1
提问于2018-11-05
得票数 0
回答已采纳
1
回答
kubernetes上的
flink
将外部jars加载到集群
、
、
我正在kubernetes (会话集群)上部署一个
flink
集群,我想知道是否有任何配置(在
flink
-conf.yaml上)可以将外部jars加载到集群
中
。据我所知,
flink
将加载lib/ folder下的所有jar,但假设我想上传用于
指标
的jar,并且我不想手动将其放入lib文件夹(因为每次部署都会将其删除),并且我不希望将lib/ folder挂载。我想要的解决方案是
创建
一个/mnt/external-jars库(这将是一个挂载),
浏览 148
提问于2020-03-14
得票数 0
1
回答
Flink
的窗口操作是处理窗口末尾的元素,还是做滚动处理?
、
我有一些困难,了解窗口是如
何在
内部实现
Flink
,并没有找到任何文章,以解释这一点的深入。在我看来,有两种方法可以做到。当窗口中的每个事件出现时,我们不会存储单个事件,而是继续将1添加到以前存储的计数器
中
,并在窗口的末尾输出结果。 是否有人能帮助您理解
Flink
在现实中使用的方法(或者可能是不同的方法)。
浏览 6
提问于2022-01-17
得票数 0
回答已采纳
1
回答
Flink
BucketingSink与NoClassDefFoundError崩溃:Lorg/apache/hadoop/fs/文件系统
、
、
"
flink
-scala" % flinkVersion % "provided", "org.apache.
flink
" %% "
flink
-statebackend-rocksdb" % flinkVe
浏览 1
提问于2018-04-03
得票数 2
回答已采纳
1
回答
Flink
web UI:监视器
指标
不起作用
、
、
、
在yarn(2.6.0-cdh5.11.1)上使用
flink
-1.9.0运行,但
flink
web ui
指标
不起作用,如下所示:
浏览 20
提问于2019-10-25
得票数 1
1
回答
Apache
flink
从late window访问键控状态
、
我正在编写一个
Flink
应用程序,它使用kafka主题中的时间序列数据。时间序列数据包含
指标
名称、标记键值对、时间戳和值等组件。我已经
创建
了一个滚动窗口,用于根据
指标
键(
指标
名称、键值对和时间戳的组合)聚合数据。我还想检查上面窗口之外是否有任何延迟到达的
指标
。我想要检查有多少
指标
延迟到达,并计算与原始
指标
相比延迟
指标
的百分比。我正在考虑使用
flink
的"allowedLateness“功能将延迟
指标
浏览 17
提问于2021-08-09
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink实现高效实时处理百万级数据:实践与优化
如何构建智能湖仓架构?亚马逊工程师的代码实践
Flink高级应用模式第一辑:欺诈检测系统案例研究
贝壳基于 Flink 的实时计算演进之路
京东Flink优化与技术实践
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券