问答 2022-11-13 来自:开发者社区

flink cdc 抽MySQL数据,一开始抽一张表,checkpoint成功了,后面加了一张表,然

flink cdc 抽MySQL数据,一开始抽一张表,checkpoint成功了,后面加了一张表,然后用一张表的时候的checkpoint路径启动,发现抽不了数,也不报错,什么原因?

问答 2022-11-05 来自:开发者社区

大佬们,我在用flink cdc 采集mysql表时,表里面有一个字段是 `signed_pdf`

大佬们,我在用flink cdc 采集mysql表时,表里面有一个字段是 signed_pdf longtext COLLATE utf8mb4_bin COMMENT '签章合同' 占用的空间很大, 代码里没有采集这个字段,但是采集任务没有输出,运行一段时间后报错(内存不足),有什么办法解决这个问...

高性能

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

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

大佬们,Flink cdc 抽MySQL,回滚到之前的checkpoint的时候,之前的tablel

大佬们,Flink cdc 抽MySQL,回滚到之前的checkpoint的时候,之前的tablelist会不起作用吗,就是不会按这个过滤表?

问答 2022-11-05 来自:开发者社区

我们在Flink Standalone 上测试 flink cdc 同步mysql历史数据的时候,当

我们在Flink Standalone 上测试 flink cdc 同步mysql历史数据的时候,当表不存在或者连接mysql超时的时候,数据同步任务会失败,同时jobmanger进程也会退出。我们准备在启动任务之前先进行mysql连接可用性和表不存在的检测。不知道大家有没有遇到过类似的问题,又是如何解决的

问答 2022-11-05 来自:开发者社区

,Flink cdc 抽MySQL,回滚到之前的checkpoint的时候,之前的tablelist

,Flink cdc 抽MySQL,回滚到之前的checkpoint的时候,之前的tablelist会不起作用吗,就是不会按这个过滤表?

问答 2022-11-03 来自:开发者社区

flink cdc 同步mysql数据库时 全量阶段出现 读取快照失败 连接重置的异常 导致应用重

,之前报的异常提示需要增加数据库的wait_timeout 时长 原本180s修改成7200s 但是测试同步到50分钟还是出现了连接重置的情况 java.lang.RuntimeException: One or more fetchers have encountered excepti...

问答 2022-10-31 来自:开发者社区

flink 15版本cdc connector同步mysql的数据,本地能拉取到数据,打jar包之后

flink 15版本cdc connector同步mysql的数据,本地能拉取到数据,打jar包之后提交就拉取不到变更数据了,而且看不到错误日志?有人遇到过这个情况吗?

问答 2022-10-31 来自:开发者社区

使用flink cdc 将mysql的数据同步到doris,mysql使用latin1编码,sink

使用flink cdc 将mysql的数据同步到doris,mysql使用latin1编码,sink到doris后编码错乱。 在mysql source表添加 jdbc.properties.characaterEncoding参数也并不起效。 大佬可以指点一下可以在哪里进行调整呢

问答 2022-10-30 来自:开发者社区

请问flink cdc支持mysql主从切换吗?

请问flink cdc支持mysql主从切换吗?

问答 2022-10-30 来自:开发者社区

flink cdc 现在支持动态添加需要同步的MySQL表吗?

flink cdc 现在支持动态添加需要同步的MySQL表吗?

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

产品推荐

实时计算 Flink

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

+关注