阿里云文档 2024-11-18

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

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

文章 2024-11-11 来自:开发者社区

如何在Flink on YARN环境中配置Debezium CDC 3.0,以实现实时捕获数据库变更事件并将其传输到Flink进行处理

随着Apache Flink的广泛应用,越来越多的企业开始采用Flink on YARN模式来部署流处理应用,以充分利用集群资源。而在现代数据栈中,变更数据捕获(Change Data Capture,简称CDC)工具扮演着重要角色,它能够实时捕捉数据库中的变化数据,并将其转发至下游系...

问答 2024-10-25 来自:开发者社区

flink1.20.0 部署后发布报错,是怎么回事,各种配置都配置了

下面是我的配置config.yaml,为什么这个taskmanager参数指定了IP,就无法发布成功了? configured separately for each TaskManager. host: 192.168.95.113 jobmanager: The host interface the JobManager will bind to. By default, this is...

文章 2024-10-14 来自:开发者社区

大数据-116 - Flink DataStream Sink 原理、概念、常见Sink类型 配置与使用 附带案例1:消费Kafka写到Redis

点一下关注吧!!!非常感谢!!持续更新!!! 目前已经更新到了: Hadoop(已更完) HDFS(已更完) MapReduce(已更完) Hive(已更完) Flume(已更完) Sqoop(已更完) Zookeeper(已更完) HBase(已更完) Redis (已更完) Kafka(已更完) ...

大数据-116 - Flink DataStream Sink 原理、概念、常见Sink类型 配置与使用 附带案例1:消费Kafka写到Redis
文章 2024-10-14 来自:开发者社区

大数据-110 Flink 安装部署 下载解压配置 Standalone模式启动 打包依赖(一)

点一下关注吧!!!非常感谢!!持续更新!!! 目前已经更新到了: Hadoop(已更完) HDFS(已更完) MapReduce(已更完) Hive(已更完) Flume(已更完) Sqoop(已更完) Zookeeper(已更完) HBase(已更完) Redis (已更完) Kafka(已更完) ...

大数据-110 Flink 安装部署 下载解压配置 Standalone模式启动 打包依赖(一)
文章 2024-10-14 来自:开发者社区

大数据-110 Flink 安装部署 下载解压配置 Standalone模式启动 打包依赖(二)

接上篇:https://developer.aliyun.com/article/1622699?spm=a2c6h.13148508.setting.15.27ab4f0eDPC5Re 服务启动 暂时就可以先启动进行测试了: cd /opt/servers/flink-...

大数据-110 Flink 安装部署 下载解压配置 Standalone模式启动 打包依赖(二)
文章 2024-10-12 来自:开发者社区

Flink-11 Flink Java 3分钟上手 打包Flink 提交任务至服务器执行 JobSubmit Maven打包Ja配置 maven-shade-plugin

代码仓库 会同步代码到 GitHub https://github.com/turbo-duck/flink-demo 上节进度 在上节中,已经使用 Dockerfile +...

Flink-11 Flink Java 3分钟上手 打包Flink 提交任务至服务器执行 JobSubmit Maven打包Ja配置 maven-shade-plugin
问答 2024-08-28 来自:开发者社区

flink 1.15x kafka pom是不是只需要 配置 这个就行了?

flink 1.15x kafka pom是不是只需要 配置 ververica-connector-kafka 这个就行了?

问答 2024-08-26 来自:开发者社区

请问一下flink cdconnector filesystem中参数能指定kerberos配置吗?

请问一下flink connector filesystem中参数能指定kerberos配置吗?有两套hadoop集群A和B,A集群未开启kerberos,B集群有kerberos认证,我现在在A集群yarn上跑任务,想通过filesystem把数据写到b集群,security.kerberos.login.keytabsecurity.kerberos.login.principal在flin....

问答 2024-08-26 来自:开发者社区

Flink CDC这个ip是代码所在机器的ip吗?端口是默认的吗,我看没地方配置端口

Flink CDC这个ip是代码所在机器的ip吗?端口是默认的吗,我看没地方配置端口

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注