问答 2023-08-02 来自:开发者社区

各位大佬,Flink CDC中为什么我跑这个mySQL的案例,这里job state一直是?

各位大佬,Flink CDC中为什么我跑这个mySQL的案例,这里job state一直是restarting呢?

问答 2023-08-01 来自:开发者社区

Flink CDC中使用TimeStamp方式的mysql datasource会包内存溢出,时间?

Flink CDC中使用TimeStamp方式的mysql datasource会包内存溢出,时间开始时间就是当开开始10分钟。大家遇到过没2023-07-28 11:18:41,709 INFO io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Keepalive thread is running2023-0...

高性能

基于 Flink CDC 打造企业级实时数据同步方案

传统的数据集成通常由全量和增量同步两套系统构成,在全量同步完成后,还需要进一步将增量表和全量表进行合并操作,这种架构的组件构成较为复杂,系统维护困难。本方案提供 Flink CDC 技术实现了统一的增量和全量数据的实时集成。
技术解决方案背景图
问答 2023-08-01 来自:开发者社区

Flink CDC读mysql,做这种状态计算,感觉不是很合适?

Flink CDC读mysql,做这种状态计算,感觉不是很合适?

问答 2023-08-01 来自:开发者社区

请问大佬Flink CDC双流join能同步删除吗? 我是直接flink mysql cdc ->

请问大佬Flink CDC双流join能同步删除吗? 我是直接flink mysql cdc -> reguler join -> mysql jdbc,表都有主键?

问答 2023-08-01 来自:开发者社区

大佬,Flink CDC啥意思,换哪里,是调整MySQL的配置吗?

大佬,Flink CDC啥意思,换哪里,是调整MySQL的配置吗?

问答 2023-08-01 来自:开发者社区

请问,flink cdc mysql漏消费数据正常吗?flink作业一直正常,但是sink端发现比

请问,flink cdc mysql漏消费数据正常吗?flink作业一直正常,但是sink端发现比source少了数据

问答 2023-08-01 来自:开发者社区

Flink cdc读取 mysql 5.7 binlog 文件时,能控制拉取速度吗?

Flink cdc读取 mysql 5.7 binlog 文件时,能控制拉取速度吗?

问答 2023-08-01 来自:开发者社区

咨询一下,Flink CDC读取Mysql binlog的时候是在哪里将binlog的数据转换成?

问题1:咨询一下,Flink CDC读取Mysql binlog的时候是在哪里将binlog的数据转换成RowData的呢,想看看varchar等字符型数据的编码转换逻辑?问题2:这里的转换和io.debezium.connector.mysql.MySqlValueConverters里的转换有什么关联吗?

问答 2023-08-01 来自:开发者社区

咨询下各位大佬,用Flink CDC 2.2.0同步MYSQL数据库,库表是latin1编码的时候?

咨询下各位大佬,用Flink CDC 2.2.0同步MYSQL数据库,库表是latin1编码的时候,读取出来的中文会是乱码,这个有什么解决方法吗?是不是SnapshotReader和BinlogSplitReader读取字符类型数据的方式也不太一样的?

问答 2023-08-01 来自:开发者社区

大佬 Flink CDC中我的MySQL时区是系统时区UTC而我们服务器时区是CST时区?

问题1:大佬 Flink CDC中我的MySQL时区是系统时区UTC而我们服务器时区是CST时区?问题2:不是我们MySQL是另外一台服务器,在MySQL中select MySQL服务时区为系统时区(也就是UTC),而要写入hudi组件的服务器是另外的一台通过linux查看是CST时区,

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

产品推荐

实时计算 Flink

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

+关注