阿里云文档 2026-01-07

使用DeleteCustomConnector API删除自定义连接器-实时计算 Flink版-阿里云

删除已经注册的自定义连接器。

阿里云文档 2026-01-07

调用API RegisterCustomConnector在项目空间注册自定义连接器-实时计算 Flink版-阿里云

在项目空间下注册自定义连接器,注册的自定义连接器可以在SQL中使用。

阿里云文档 2026-01-07

调用ListCustomConnectors获取自定义连接器列表-实时计算 Flink版-阿里云

获取已注册的自定义连接器的列表信息。

阿里云文档 2024-11-18

如何配置Flink自定义指标采集

当您的Prometheus实例需要监控Flink自定义指标数据时,您可以通过自定义指标配置功能来实现这一需求。将指标加入到自定义指标配置后,它们将被探针(Agent)侧识别并采集。默认支持两种配置方式:指标全名称配置,指标前缀配置,您还可以对两种方式进行组合配置。

阿里云文档 2024-11-18

如何配置Flink自定义指标采集

当您的Prometheus实例需要监控Flink自定义指标数据时,您可以通过自定义指标配置功能来实现这一需求。将指标加入到自定义指标配置后,它们将被探针(Agent)侧识别并采集。默认支持两种配置方式:指标全名称配置,指标前缀配置,您还可以对两种方式进行组合配置。

问答 2022-04-24 来自:开发者社区

我自定义了一个Kafka reporter用来上报flink的metric,但是写不到Kafka

自定义了一个Kafka reporter继承abstractreporter类,实现scheduled接口,重写了report方法,将数据发送至Kafka,在配置文件也正确配置了,但是Kafka里没数据

问答 2021-12-07 来自:开发者社区

自定义metrics reporter 如何不通过flink conf来注册并生效

Hi all, 请问实现了 MetricReporter, CharacterFilter,Scheduled, Reporter 的自定义 customerReporter 如何能在 代码env里面注册并实现metric上报,要求不在flink conf.xml 文件里面配置 该customerReporter的信息? 需求:在自定义的source 和sink等算子里面计算处理成功,失败的...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注