腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(52)
视频
沙龙
2
回答
Flink
1.14中
的
Lantency
监控
apache-flink
我正在跟踪此
Flink
tutorial以进行反应式扩展,并有兴趣了解工作节点数量
的
快速变化对总体端到端延迟有何影响。根据documentation,我已经将metrics.latency.interval: 1000添加到配置映射中,因为我知道将添加一个新
的
延迟度量,并每隔1秒发送一次标记。然而,我似乎在普罗米修斯中找不到相应
的
直方图。下面列出了与延迟相关
的
可用指标: ? 我使用
的
是
Flink
1.14。我是不是漏掉了什么?
浏览 59
提问于2021-10-12
得票数 0
1
回答
嵌入式
Flink
实例
的
JobManager在哪里?
apache-flink
、
flink-streaming
我正在开发一个具有多个(微)服务
的
应用程序。谁在管理这些作业?如何
监控
处理过程?摩西
浏览 1
提问于2017-03-29
得票数 0
1
回答
Flink
:如何实时
监控
作业
apache-flink
、
flink-streaming
我们如何实时
监控
flink
作业。例如,如果作业失败,则会生成一些警报。是否存在任何外部库,或者
flink
中已有可用
的
库。提前谢谢。
浏览 14
提问于2021-06-02
得票数 1
1
回答
如何识别
flink
中
的
状态?
apache-flink
有没有一种方法来
监控
Flink
的
状态?我
的
意思是,如果我在
Flink
应用程序中使用状态,那么我想知道
Flink
中状态
的
状态或正在进行
的
值。谢谢。
浏览 4
提问于2022-10-25
得票数 0
回答已采纳
1
回答
Apache
Flink
REST API
的
身份验证
apache-flink
有没有办法限制对Apache
Flink
提供
的
REST API
的
访问,例如使用Basic Auth、Api-Key等? 我指的是“
监控
REST API”(令人困惑
的
不仅是
监控
,还包括作业控制)。
浏览 3
提问于2017-10-16
得票数 2
1
回答
Flink
CLI与
Flink
Web控制台
apache-flink
我们需要替换
flink
控制台UI,并使用CLI实用程序启用
Flink
Web控制台
的
所有功能,对于一些功能,如启动作业、保存点等,我们使用
的
是
Flink
CLI。我
的
问题是我正在寻找一种解决方案,在这种解决方案中,待命工程师可以使用命令行/终端完全
监控
并在
flink
浏览 3
提问于2022-01-03
得票数 0
回答已采纳
1
回答
你能从Apache
Flink
operator访问isBackPressured吗?
apache-flink
、
flink-streaming
、
flink-cep
我已经为Apache
Flink
编写了一个java程序。我想定期执行一些计算,所以我使用计时器来触发重新计算。例如,每10秒,实现花费大约1秒(软阈值)来更新状态。所以我想知道,如果执行重新计算
的
任务槽(SubTask)是背压
的
,您是否可以访问操作员中
的
任何背压指标来跳过重新计算?我在getRuntimeContext().getMetricGroup()里搜索了一下,但没有找到任何有用
的
东西。
浏览 5
提问于2021-09-28
得票数 0
1
回答
如何向EMR提交
flink
流作业?
apache-flink
、
airflow
、
amazon-emr
、
flink-streaming
我有几个要在AWS EMR上运行
的
长时间运行(流)
flink
作业。我从AWS控制台或使用aws cli阅读了执行此操作
的
步骤。但这是手动
的
。
浏览 28
提问于2019-12-11
得票数 1
2
回答
Flink
Eclipse JDT编译器问题
java
、
eclipse
、
aws-lambda
、
apache-flink
、
flink-cep
我正在尝试运行这个程序:
Flink
CEP
监控
缺少“Map”
的
泛型类型参数。您
的
编译器似乎没有将它们存储到.class文件中。目前,只有Eclipse编译器保存使用lambdas特性类型所需
的
类型信息--安全。有关如何编译包含lambda表达式
的
作业
的
详细信息,请参阅文档。org.apache.
flink
浏览 3
提问于2016-05-05
得票数 2
2
回答
用
Flink
从卡夫卡主题开始
的
消费
scala
、
apache-kafka
、
apache-zookeeper
、
apache-flink
、
flink-streaming
如何确保我总是从
Flink
?的卡夫卡主题开始就开始消费?
Flink
将偏移作为其分布式检查点
的
一部分进行内部快照。卡夫卡/ ZooKeeper
的
补偿只会使外界对进步
的
看法与弗林克对进步
的
看法同步。这样,
监控
和其他工作就可以了解到
Flink
Kafka消费者已经消耗了多少话题。这就是我取得
浏览 2
提问于2016-05-09
得票数 2
1
回答
如何通过
flink
rest api获取作业名称?
apache-flink
我正在尝试通过
flink
作业
的
名称来
监控
它们
的
状态。 但是我没有发现任何rest api可以从这个site返回作业名称。 我怎么才能得到它呢?
浏览 23
提问于2019-03-12
得票数 1
回答已采纳
2
回答
如何使用Java代码将作业提交给
Flink
集群?
java
、
deployment
、
apache-flink
、
flink-streaming
我已经将包含应用程序代码
的
胖jar上载到
Flink
集群中所有节点
的
/lib文件夹中。我正在尝试从一个单独
的
java应用程序启动
Flink
作业,但是找不到一个很好
的
方法。与我目前找到
的
解决方案最接近
的
是具有的
监控
Rest。但是,这只允许您运行通过作业上载函数提交
的
作业。我在
flink
客户端模块中看到了ClusterClient.java,但没有看到如何使用它
的
任何示例。 如
浏览 12
提问于2020-01-28
得票数 4
1
回答
是否可以在
Flink
中
的
Job Manager上注册指标?
apache-flink
我想向我们
的
监控
系统公开有关当前在k8s上运行
的
作业版本
的
信息。目前,在Job Manager上公开
的
简单指标就足够了。可以在
Flink
中注册这样
的
指标吗?
浏览 19
提问于2020-01-24
得票数 0
1
回答
收集
flink
扁平图函数所用平均时间
的
度量
apache-flink
、
prometheus
、
metrics
我已经实现了一个
flink
扁平图函数,我想收集该函数
的
平均时间指标,我计划通过prometheus
监控
该函数。 有什么好
的
方法可以解决呢?我已经在方法中添加了一个仪表(从
flink
API扩展仪表接口)。
浏览 8
提问于2021-01-12
得票数 1
回答已采纳
1
回答
是否可以在需要时调用闪烁映射(不在输入流上激活)
scala
、
apache-flink
、
flink-streaming
我在
flink
中有一个地图,一旦数据通过流,它就会被激活。 即使没有数据通过,我也要调用该地图。 我将map移动到一个函数中(无限函数调用),但是
flink
作业永远不会运行。这个想法是,在一个无限循环中有一个映射,检查一些共享变量,另一个
flink
流
监控
kafka队列,如果数据进入它
的
进程,它会改变一个共享变量,以某种方式影响无限循环并继续。如何调用无限循环映射并同时运行
flink
映射?我尝试使用随机数据创建一个CollectionMap来激活流和映射以调用无限循环,但几乎立即退出,即使
浏览 28
提问于2019-05-07
得票数 1
1
回答
Kubernetes Autoscaling -事件触发
kubernetes
、
apache-flink
我正在尝试让
Flink
集群在kubernetes之上运行。由于当前
的
Flink
1.3.1还不支持动态缩放,因此当使用kubernetes进行扩展/缩小时,我想触发我
的
自定义脚本从保存点停止并重新启动作业。Kubernetes中是否有这样
的
特性,我可以在自动缩放中有一个前/后事件触发点,这样我就可以在自动缩放完成它
的
工作后运行自定义脚本?或者现在唯一
的
选择就是编写我自己
的
cron
监控
来使用kubectl scale
浏览 5
提问于2017-08-09
得票数 0
回答已采纳
2
回答
flink
kafka消费者groupId不起作用
apache-kafka
、
apache-flink
我用
的
是卡夫卡和
flink
。在一个简单
的
程序中,我使用
flink
FlinkKafkaConsumer09,将组id分配给它。我认为这应该是这样
的
:如果向Kafka发送2条消息,那么
flink
程序中
的
每条或一条将处理这2条消息完全两次(假设总共有2行输出)。我试图使用两个卡夫卡消费者在相
浏览 10
提问于2016-07-28
得票数 6
回答已采纳
1
回答
有没有办法丢弃部分匹配?
apache-flink
、
flink-cep
我在
监控
车辆
的
动向。每当他们进入或离开geofence时,都会触发一个事件。通过
Flink
,我想检查一辆车是否在栅栏内至少两个小时。下面是我使用
的
模式: begin("enter").notFollowedBy("exit").within(Time.hours(2)).followedBy("final-exit") 问题是:即使退出有没有办法告诉
Flink
主动放弃部分匹配?
浏览 36
提问于2020-12-16
得票数 0
回答已采纳
1
回答
需要用于
flink
1.3.3
的
prometheus库
apache-flink
、
prometheus
、
flink-streaming
我们计划使用普罗米修斯进行指标
监控
,目前我们
的
大多数应用程序都运行在
FLINK
1.3.3 .Is中,有没有普罗米修斯指标jar可以做到这一点?我检查了maven ..Dont是否有超过1.4.0
的
内容
浏览 3
提问于2020-06-15
得票数 0
2
回答
Flink
不对kafka进行抵消
java
、
scala
、
streaming
、
apache-kafka
、
apache-flink
我有一个
flink
流媒体工作,是从卡夫卡读取数据,并只是记录它。我启用了检查点。任何帮助都是徒劳无功
的
。KAFKA_HOME/bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group
flink
-consumer-groupError while executing consumer group command Group
浏览 5
提问于2017-02-06
得票数 3
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
美团点评实时计算平台的Flink监控与告警实践
百亿条日志实时处理,为什么要用Flink?
《从0到1学习Flink》——Apache Flink 介绍
58同城基于Flink的千亿级实时计算平台架构实践
58同城实时计算平台架构实践
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券