问答 2024-04-14 来自:开发者社区

Flink CDC同一条数据的话,那不是同一个主键嘛,并行度高会不会出现顺序错乱导致数据错误?

Flink CDC同一条数据应该是同一个主键吧?读进来的时候应该会有顺序,但是写出的时候,并行度高会不会出现顺序错乱导致数据错误?

问答 2024-04-14 来自:开发者社区

flink cdc同步mysql数据失败,查了一下是连接中断,网络问题等等,不知道如何解决?

"flink cdc同步mysql数据失败,查了一下是连接中断,网络问题等等,不知道如何解决用的是flinksql 总共是5W多的数据量 同步到4W多开始报错 其他的表可以正常实时增量同步 只是数据量比较少 只有几十条 或者上千条"

问答 2024-04-14 来自:开发者社区

flink cdc同步mysql数据失败,查了一下是连接中断,网络问题等等,不知道如何解决?

"flink cdc同步mysql数据失败,查了一下是连接中断,网络问题等等,不知道如何解决?下面是报错用的是flink sql"

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

Flink CDC一秒钟16000条数据,数据比这多都没什么延迟,为什么?

Flink CDC有个消费kafka的问题很困惑,一秒钟16000条数据,flink就消费,没计算,延迟能到半小时,测试环境非常差,数据比这多都没什么延迟?

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

使用Flink CDC + debezium 同步 sql Server 数据时,报错,怎么解决?

使用Flink CDC + debezium 同步 sql Server 数据时,处理schemaChangeEvent时报错,怎么解决?Caused by: org.apache.kafka.connect.errors.DataException: file is not a valid field name

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

Flink CDC上下游不一致的原因不是主键不一致是因为我数据筛选时候用了trim()后就不一致吗?

Flink CDC上下游不一致是因为我数据筛选时候用了trim()吗?【insert into target select trim(xxx) from source】

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

flink cdc动态获取同步表数据到es,没有监听数据为啥?

flink cdc动态获取同步表数据到establelist t_abc.*创建表结构 t_abcd,并且向t_abcd insert数据flink cdc 并没有监听获取到t_abcd insert 数据,这样正常吗?

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

Flink CDC里Oracle cdc latest 同步模式 如何找丢失数据?

Flink CDC里Oracle cdc latest 同步模式 flink stop后再从savepoint恢复,丢了一小段数据怎么搞呢?

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

Flink CDC里我代码里设置了 这个,拉取不到历史数据怎么办?

Flink CDC里我代码里设置了 StartupOptions.initial();拉取不到历史数据怎么回事呢?

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

Flink CDC里有什么好的办法能监听oracle数据变化吗?必须linux上部署吗?

Flink CDC里有什么好的办法能监听oracle数据变化吗?必须linux上部署吗?我现在想用oracle那个消息机制,一直没研究明白,监听不到。

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等