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

请问下大佬们,flink cdc 同步mysql出现TBL_ID为空是什么情况呢?

请问下大佬们,flink cdc 同步mysql出现TBL_ID为空是什么情况呢?Caused by: java.lang.IllegalArgumentException: Unexpected value for JDBC type -5 and column TBL_ID BIGINT(20) NOT NULL: class=class [B

问答 2023-07-31 来自:开发者社区

有大佬在阿里云E-MapReduce线上用过Flink cdc CDAS 同步数据到SR的吗?

有大佬在阿里云E-MapReduce 线上用过 Flink cdc CDAS 从 mysql 分库分表同步数据到SR的吗?库和表比较多的话性能ok吗?

高性能

Flink CDC 实现企业级实时数据同步

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

大佬Flink CDC这个整库同步的问题 如何解决?是资源不够吗?

大佬Flink CDC这个整库同步的问题 如何解决?是资源不够吗?

问答 2023-07-31 来自:开发者社区

Flink CDC中Oracle 只能从主库同步是吧?

Flink CDC中Oracle 只能从主库同步是吧?

问答 2023-07-28 来自:开发者社区

使用flink cdc 同步数据到sr 有使用界面化的任务配置管理工具吗?

使用flink cdc 同步数据到sr 有使用界面化的任务配置管理工具吗?

问答 2023-07-26 来自:开发者社区

Flink CDC中 flink离线同步,是不是不支持删除么?

Flink CDC中 flink离线同步,是不是不支持删除么?sink表和source表定义了主键,源表删除了一条数据,同步后目标表并没有删除数据。我是将mysql表同步到sqlserver。

问答 2023-07-26 来自:开发者社区

Flink CDC中我的场景是同步Mysql数据到es中,应该怎样写才可以插入一组数据?

Flink CDC中我的场景是同步Mysql数据到es中,es索引对应的类型是一个数组,我在flink sql中创建了对应的类型 regions ARRAY>, 那insert into到 es_index应该怎样写才可以插入一组数据,我使用insert into es_index select ROW(regionId, regionName) AS regions from ... 只能...

问答 2023-07-26 来自:开发者社区

Flink CDC中增量监听binlog日志同步的时候也会把全部数据都加载到内存吗?

Flink CDC中增量监听binlog日志同步的时候也会把全部数据都加载到内存吗?有没有试过?我现在还在全量同步阶段,如果单独的增量同步不存在全部加载到内存的问题的话,可不可以先用维表的方式做完全量同步。然后再全部流表,但是启动时跳过快照阶段,直接指定位点启动一个新的任务做后续更新同步。

问答 2023-07-26 来自:开发者社区

Flink CDC中如果其他的表用了jdbc,那后面这些其他表有更新,能同步过来吗?

问题1:Flink CDC中如果其他的表用了jdbc,那后面这些其他表有更新,能同步过来吗?还会是一张流表吗?It also prevents that the join result is updated when a joined Customer row is updated in the future. 我看官方文档这意思是,其他的表就彻底成了一张维表了,其他表有更新也不会做同步。问题2....

问答 2023-07-26 来自:开发者社区

Flink CDC中当前是启动任务全量数据可以同步,增量数据不同步怎么排查?

Flink CDC中,我是flink1.17.1+mysql cdc2.4.0+mysql5.7(source端),当前是启动任务全量数据可以同步,增量数据不同步,checkpoint开启了,也没见什么异常信息。怎么排查?我这边使用的Dinky,通过SQL的方式做的,如下是SQL配置部分

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

产品推荐

阿里云实时计算Flink

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

+关注