Flink CDC里tidb 同步数据自定义sink 老是出现这两个报错 是怎么回事呢?

Flink CDC里tidb 同步数据自定义sink 老是出现这两个报错 是怎么回事呢?连接是用的 flink sql 写是自定义sink。这个是偶尔出现 我看源码那儿 我按理说数据是有的 任务不会一会儿正常一会空指针吧?

Flink CDC里自定义udf函数的eval有线程安全问题吗?需要加sync那个锁吗?

Flink CDC里自定义udf函数的eval有线程安全问题吗?需要加sync那个锁吗?

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

[帮助文档] 自定义聚合函数UDAF的开发、注册和使用流程

本文为您介绍如何为Flink自定义聚合函数(UDAF)开发、注册和使用流程。

阿里云Flink-自定义kafka sink partitioner实践及相关踩坑记录

阿里云Flink-自定义kafka sink partitioner实践及相关踩坑记录

1. 背景及需求链路:Flink -> sink kafka需求:客户需求根据数据的特征,以自定义的逻辑,将不同的数据写到kafka不同的分区中阿里云官方文档链接:https://help.aliyun.com/zh/flink/developer-reference/kafka-connec...

请教一个flink-stream 的问题,在自定义sink中如何读取该广播流 的数据?

请教一个flink-stream 的问题,在作业中我定义了一个 广播流,将该广播流将一些配置信息动态广播到下游算子中,也实现了BroadcastProcessFunction 类,可正常操作 广播流数据。但在自定义sink中如何读取该广播流 的数据?

Flink CDC自定义的sink端连接mysql久了报错,有人知道怎么解决吗?

Flink CDC自定义的sink端连接mysql久了报错Communications link failure有人知道怎么解决吗?

Flink自定义sink写入mysql

采用mybatis配置参考:https://blog.csdn.net/weixin_43291055/article/details/100152026只需要在sink的时候自定义sink即可,核心代码如下:public class SinkTest extends RichSinkFunctio...

Flink自定义source、自定义sink

1.自定义source  继承RichSourceFunctionpublic class TestSource extends RichSourceFunction<String> {    private volatile boolean isRunni...

Flink CDC用的stream api 自定义反序列化器显示类型转换问题?

Flink CDC用的stream api 自定义反序列化器显示类型转换问题?

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

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199197+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载