问答 2025-03-21 来自:开发者社区

flink1.19和hive3.1.3,cdc从mysql同步数据到hive,插入时报错?

使用的是flink sql处理流程是从mysql进kafka之后,通过kafka插入hive,在插入数据时会报错,选了upsert-kafka,sql没有更新或者删除操作 Flink SQL> [ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.api.TableException: Table si...

问答 2024-05-20 来自:开发者社区

Flink CDC里mysql到doris 同步 用yaml配置文件很方便 以后会增加更多数据吗?

Flink CDC里mysql到doris 同步 用yaml配置文件很方便 以后会增加更多数据源快速配置同步?今年之内能有pg到doris吗?

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

Flink CDC里我有张mysql表,配置的是init,每次都是同步一条数据,然后就不同步了为啥?

Flink CDC里我有张mysql表,配置的是init,试了好几次,每次都是同步一条数据,然后就不继续同步数据了,可能是啥原因?

问答 2024-03-20 来自:开发者社区

Flink CDC 里mysql->Doris的整库同步,没有成功自动建表以及同步数据?

Flink CDC 里java.lang.IllegalStateException: Failed to send request to coordinator: com.ververica.cdc.runtime.operators.schema.event.SchemaChangeRequest@3d93dee1 mysql->Doris的整库同步,没有成功自动建表以及同步数据?Fli...

问答 2024-02-26 来自:开发者社区

Flink CDC里mysql-cdc同步到kafka中,对同一条数据多次操作,怎么区分先后?

Flink CDC里mysql-cdc同步到kafka中,对同一条数据多次操作,op_ts字段可能会一样,如何区分先后顺序呢?同一条数据在短时间内有i、d、u操作,操作时间读取过来也是同一个,这咋区分哪个前哪个后呢?

问答 2024-02-06 来自:开发者社区

Flink CDC里在生产跑 MySQL 向 Doris 同步数据,可以直接用 这个吗?

Flink CDC里在生产跑 MySQL 向 Doris 同步数据,可以直接用 QuickStart 里介绍的一样,通过 yaml 来编写 task 配置信息,cdc 脚本启动 flink job 就可以了么,区别只是生产要一个稳定的 flink 集群? 因为我看 flink-cdc 的release 包里,其实就是依赖 cdc 的包和 pipline 的包,pipline 的话是对 conne....

问答 2024-01-18 来自:开发者社区

Flink CDC我配置mysql CDC,但任务重启(重新执行)后,它总是全量同步数据,要怎么做?

Flink CDC里我配置mysql CDC,但是任务重启(重新执行)后,它总是全量同步数据,具体有什么参数可以配置使用增量同步啊?

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

Flink CDC从mysql同步数据到doris,这是咋回事?

Flink CDC从mysql同步数据到doris,同步的历史数据中时间字段类型都是null,但是增量部分的时间类型的字段都会正常显示,这是咋回事?

问答 2023-12-24 来自:开发者社区

Flink CDC有什么方案从mysql同步数据到mysql吗? 支持全量和增量的?

Flink CDC有什么方案从mysql同步数据到mysql吗? 支持全量和增量的?~~~~

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

产品推荐

阿里云实时计算Flink

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

+关注