问答 2024-11-19 来自:开发者社区

flinksql同步mysql数据到doris提示incompatible types

flink版本为:1.19cdc任务报错,请问是否是mysql8.x的配置有什么问题?具体报错如下: Caused by: java.io.InvalidClassException: org.apache.flink.cdc.connectors.shaded.com.fasterxml.jackson.databind.cfg.MapperConfig; incompatible ty...

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

flinksql cdc 是不是只有从mysql同步到kafka 才能截取到这个字段?

flinksql cdc 是不是只有从mysql同步到kafka 才能截取到op before after字段?

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

如果用flinksql的方式同步mysql数据到kafka,是类似DTS那样吗?

如果用flinksql的方式同步mysql数据到kafka,是类似DTS那样只要数据变更有binlog就会往kafka投递消息么?

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

截图里面的flinksql,为什么不用填mysql的地址 账号和密码,但可以部署运行?

截图里面的flinksql,为什么不用填mysql的地址 账号和密码,但可以部署运行?

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

在Flink CDC中flinksql写入到mysql的sink应该怎么写?

在Flink CDC中flinksql写入到mysql的sink应该怎么写?

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

flinksql 读取kafka数据 写入到mysql 按照主键更新 会不会导致数据乱序?

flinksql 读取kafka数据 写入到mysql 按照主键更新 如果上游并行度是3 再mysql ddl中设置sink.parallelism=2 会不会导致数据乱序啊 哪位大佬知道?还有就是 flinksql 有办法 实现keyby么。 控制按照哪个字段分区?

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

用flinkSQL请问这是不是在flink/lib目录下缺少了相关的mysql连接包?

用flinkSQL创建MySQL外表时报了个错,请问这是不是在flink/lib目录下缺少了相关的mysql连接包?想问下具体是咋解决这样的问题呢?

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

Flink CDC里flinksql 一个并发写mysql 正常,2个并发消费任务都正常,为啥这样?

Flink CDC里flinksql 一个并发写mysql 正常,2个并发消费任务都正常,但是mysql 没有数据写入为啥?数据量是够的,消费任务都正常,就是没有数据写入,不知道数据怎么凭空消失了?

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

FLinkSQL同步MySQL时,有遇到上游批量删除20w数据的场景吗?

FLinkSQL同步MySQL时,有遇到上游批量删除20w数据的场景吗,sink端一条条删除非常慢要怎么处理啊,2个小时都删不完?

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

Flink CDC中flinksql采集mysql,这怎么解析到kafka,有方法解决吗?

Flink CDC中flinksql采集mysql,mysql字段类型是blob,数据是压缩后写入的,这怎么解析到kafka,有方法解决吗?

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

产品推荐

数据库

数据库领域前沿技术分享与交流

+关注
相关镜像
AI助理

你好,我是AI助理

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