腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
Flink
statsD
集成
、
、
我们在启用了多主机模式的EMR 5.29上使用
Flink
1.9.1。我们将以下配置添加到conf文件夹中的
flink
-conf.yaml文件中,并将jar
flink
-metrics-
statsd
-1.9.1.jar添加到
flink
/lib文件夹中。<subtask_index> metrics.reporter.stsd.factory.class: org.apache.
flink
.metrics.
st
浏览 20
提问于2020-07-13
得票数 1
回答已采纳
1
回答
Flink
与Datadog的
集成
、
、
、
、
我有几个关于
Flink
和Datadog
集成
的问题。首先,问题是Datadog使用的是dogstatsD,而不是不包含在
Flink
文档中的
statsD
。 另一个问题是,如果您转到Datadog的页面,则缺少
Flink
集成
。我尝试过安装石墨,但由于python3.6,我也尝试过使用datadog,这也给我带来了一些问题,这也给我带来了困难。
浏览 11
提问于2017-10-27
得票数 0
回答已采纳
1
回答
与
StatsD
计数器度量比较的
Flink
、
、
谈到有关
StatsD
的计数器,它的工作方式是您一直张贴一个计数器的值。每当应用程序收到对
StatsD
守护进程的请求时,都会使用
StatsD
。试图把这个映射到
Flink
计数器。因此,应将
flink
计数器报告为
StatsD</em
浏览 2
提问于2020-01-23
得票数 0
1
回答
如何在
Flink
1.11中启用度量
我是
flink
的新手,我正试图在emr集群上从
flink
1.8升级到
flink
1.11。升级到
flink
1.11之后,我看到的一个不同之处是,我没有得到任何度量。我发现
flink
1.11在/usr/lib/
flink
/opt中没有org.apache.
flink
.metrics.
statsd
.StatsDReporterFactory jar,这是
flink
是否有人有任何指针来定位or
浏览 2
提问于2020-10-22
得票数 0
1
回答
无法从
Flink
1.15.0作业发送应用程序级别的指标
我正在将
Flink
1.9.1集群升级到
Flink
1.15.0集群。这要求我更新
Flink
作业代码中的
Flink
API。然后,
flink
-metrics-
statsd
插件处理将度量发送到
StatsD
端点的部分。我已经确认在
StatsD
端点上使用tcpdump发送了系统级别的度量,但是我在代码中显式注册的度量在哪里都看不到。 旧
Flink
1.9.1上相同的度量注册代码运行良好,并发出所有这些指标。at org.apache.<em
浏览 43
提问于2022-07-19
得票数 0
回答已采纳
1
回答
找不到报告程序influxdb
、
我使用了
flink
1.11,但任务管理器找不到org.apache.
flink
.metrics.influxdb.InfluxdbReporterFactory WARN org.apache.
flink
.runtime.metrics.ReporterSetupAvailable factories: [org.apache.
flink
.metrics.datadog.DatadogHttpReporterFactory, org.apache.
flink
.metrics.slf4j.Slf4jRe
浏览 47
提问于2020-07-17
得票数 0
回答已采纳
1
回答
Flink
监控:捕获统计数据超过5分钟
、
、
我是
Flink
社区的新手,我正在尝试做一项实验研究,以捕获
Flink
对流数据的性能。为此,我尝试收集几个小时内正在运行的作业的统计数据。但是,使用
Flink
的UI,我只能看到过去5分钟的统计数据。
浏览 3
提问于2017-11-15
得票数 0
1
回答
我的自定义
flink
度量报告不工作
、
使用
flink
版本1.13.12021-08-25 14:54:06,243 WARN org.apache.
flink
.runtime.metrics.ReporterSetup, org.apache.
flink
.metrics.
statsd
.StatsDReporterFactory, org.apache.
flink
.metrics.
浏览 10
提问于2021-08-25
得票数 2
回答已采纳
1
回答
获取NSolid历史数据
是否为主机保存历史数据?当进程退出时,该主机的数据似乎已经消失,至少来自UI。
浏览 4
提问于2016-03-14
得票数 0
回答已采纳
3
回答
使用
statsd
-bridge将数据从
statsd
推送到prometheus
、
、
、
我一直在我的python django应用程序中使用
statsd
来测量不同的指标。现在,我们已经
集成
了prometheus io,以便我们可以在以后的时间点查询这些指标。在这种情况下,我经历了
statsd
_bridge 。我使用它的方式如下: ./
statsd
_bridge -
statsd
.listen-address="localhost:9090“-
statsd
.mapping-config="”-web.listen-address="a.b
浏览 0
提问于2015-03-23
得票数 2
2
回答
如何在AWS (ElasticMapReduce)中监视Apache?
、
、
我现在已经设置了
Flink
,并在EMR上运行了一个作业,现在我正试图通过将指标发送到prometheus来添加监视。 “要使用此记者,必须将/opt/
flink
-metrics-prometheus-1.6.1.jar复制到
Flink
发行版的
浏览 0
提问于2019-03-06
得票数 4
回答已采纳
2
回答
flink
ReducingState影响性能
、
发现当我们使用ReducingState RecordStore.add(r)时,性能会出现如下所示的波动:使用ReducingState:它可以很容易地通过一个简单的应用程序重现,没有检查点,只需简单地保存记录,也可以使用简单的“sum”缩减函数(实际上使用empty函数也会看到同样的结果)。任何想法都将不胜感激。多么令人难以置信的显而易见的问题。 基本上,应用程序只是将记录存储到状态中,我们在"JsonTranslator“中测量每秒有多少条记录,如图所示。区别只有一行,注释/取消注释"recStore
浏览 3
提问于2018-05-29
得票数 0
2
回答
是否可以查询Jetty Server以获取统计信息?
、
我想定期将此作为计数发送到我的
statsd
代理,以便能够在Grafana上绘制它。但我在Server类上找不到任何公开此类指标的公共apis。 我猜还有其他人已经在这么做了。
浏览 4
提问于2021-01-30
得票数 3
1
回答
用Datadog监测数据流管道
、
目前,Datadog为其他GCP服务提供
集成
,但不为Dataflow提供
集成
。是否有人做过类似的工作,并且可以分享如何将其构建为自定义解决方案?
浏览 1
提问于2017-11-30
得票数 2
1
回答
如何将Datadog中的度量与
Flink
中的执行计划运算符联系起来?
、
、
在我的场景中,
Flink
将度量标准发送到Datadog。Datadog主机映射如下所示:{我不知道为什么在这里显示延迟)
Flink
指标被发送到本地主机。这里的问题是 # adding metrics metrics.reporter.stsd.class: org.apache.
flink
.metrics.
statsd
.StatsDReporter metrics.repor
浏览 8
提问于2017-10-29
得票数 0
回答已采纳
2
回答
无法查看
statsd
发送的datadog上的指标。
、
我正在尝试
集成
statsd
+datadog。我正在使用来测试
集成
浏览 5
提问于2021-05-03
得票数 1
回答已采纳
1
回答
如何在Intellij IDEA中调试
flink
流作业
、
、
、
、
我想创建一个带有一些逻辑(Scala)的
Flink
Job,并在文档中找到了几种启动
Flink
的方法。例如,独立模式: ./bin/
flink
run ./examples/streaming/TopSpeedWindowing.jar 它可能是从Intellij Idea启动和调试
Flink
作业,就像使用主类启动和调试简单的Spark job一样吗?def main(args: Array[String]): Unit = { }
浏览 42
提问于2021-01-30
得票数 0
1
回答
测试kafka和
flink
集成
流程
、
、
、
例如,我想测试卡夫卡/
Flink
与FlinkKafkaConsumer011和FlinkKafkaProducer011的
集成
。这一进程将是: 谢谢!
浏览 0
提问于2018-04-16
得票数 3
2
回答
Apache
Flink
1.4与Apache Kafka 1.0.0
、
、
、
我试图让Apache项目与Apache 1.0.0
集成
。当我试图在我的build.sbt文件中添加
flink
连接器-kafka包时,我会看到一个错误,它不能解决它。val flinkVersion = "1.4.1" "org.apache.
flink
" %% "
flink
-scala" % flinkVersion% "provided", "org.apac
浏览 2
提问于2018-03-03
得票数 2
回答已采纳
1
回答
可以将apache ranger/atlas与apache
flink
集成
吗?
、
、
Flink
在这方面做得很好,而且
flink
sql客户端看起来非常有前途。我正在尝试理解,当用于交互式查询时,是否有可能将治理工具与
flink
sql客户端
集成
。
浏览 36
提问于2020-04-30
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink CDC 如何与其他 Flink 特性集成?
Flink集成Iceberg在同程艺龙的实践
Stateful Functions开源:集成了Flink和FaaS的流处理优点
字节跳动基于Flink的MQ-Hive实时数据集成
Flink基础教程(二):初探Flink
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券