问答 2024-07-16 来自:开发者社区

Flink1.18.1 CDC Mysql数据到Doris报错

Flink1.18.1+flink-sql-connector-mysql-cdc-3.0.1.jar 同步Mysql数据到Doris中,数据能全部同步到Doris中,只是过一长段时间后 任务会报错,请问是什么原因?如果是connector包版本问题,那么请问配套的版本号又是多少?具体错误如下:2024-07-16 18:19:22java.lang.RuntimeException: One ....

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

在Flink CDC中同步Mysql数据,数据能全部同步到目标,只是过一段时间后 任务会报错为什么?

在Flink CDC中同步Mysql数据,数据能全部同步到目标,只是过一段时间后 任务会报错,请问是什么原因?请参考图片:

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

flink cdc 能捕获 mysql 的如下的数据变化吗?

flink cdc 能捕获 mysql 的 ALTER TABLE table_name drop PARTITION PARTITION ${f}${p_3} ;的数据变化吗?

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

Flink CDC从mysql到doris,Flink Job提交后,数据会立即同步这个会是啥原因?

Flink CDC从mysql到doris,Flink Job提交后,数据会立即同步,后面mysql增量数据不同步,这个会是啥原因?

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

flink cdc 读取mysql 。我们希望拿到增和删,改的数据都拿到。存到odps中。可以做嘛?

flink cdc 读取mysql 。我们希望拿到增和删,改的数据都拿到。存到odps中。请问可以做到吗?

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

在Flink CDC中MYSQL cdc ds代码开发 通过正则的方式获取数据,这个正则格式怎么写?

在Flink CDC中MYSQL cdc ds代码开发 通过正则的方式获取数据,这个正则格式怎么写?

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

在Flink CDC中再用CDC同步MySql数据的时候,哪个配置能够过滤掉脏数据呢?

在Flink CDC中再用CDC同步MySql数据的时候,哪个配置能够过滤掉脏数据呢?

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

flink cdc抽mysql中的数据和实时数据流进行join,托管内存为什么会直接被拉满?

我用flink cdc抽mysql中的数据和实时数据流进行join,flink的托管内存在任务启动时就直接拉满了,但是实际的cdc抽的数据时没有这么多的,预估的cdc抽过来的数据只有2g,请问托管内存为什么会直接被拉满?

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

在Flink CDC中为什么mysql中新增数据,在kafka中,消费者看不到新增的数据?

在Flink CDC中flink1.18.0,mysql同步到kafka,为什么mysql中新增数据,在kafka中,消费者看不到新增的数据?

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

flink cdc整库同步mysql数据到doris,报错找不到mysql驱动包如何操作?

flink cdc整库同步mysql数据到doris,按照官网教程操作,报错找不到mysql驱动包,如何操作?请参考图片:

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

产品推荐

阿里云实时计算Flink

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

+关注