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

Flink CDC中kafkasink时报序列化错误,有同学遇到吗?

Flink CDC中kafkasink时报序列化错误,有同学遇到吗,本地idea正常运行,提交到集群一直报这个错?

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

Flink CDC一样的报错哈,这错误看起确实像序列化问题?

Flink CDC一样的报错哈,这错误看起确实像序列化问题:Caused by: java.io.InvalidClassException: org.apache.flink.streaming.connectors.kafka.table.DynamicKafkaRecordSerializationSchema; local class incompatible: stream class....

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

老哥,Flink CDC中我这边从mysql监控两个表往es塞 ,反序列化怎么搞啊?还有我怎么区分是

问题1:老哥,Flink CDC中我这边从mysql监控两个表往es塞 ,反序列化怎么搞啊?还有我怎么区分是哪个表过来的,而且两个表有相同字段问题2:主要我这边去往es塞的时候这个泛型怎么给

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

Flink CDC有大佬知道这啥原因吗?这是序列化有问题吗,用的群文件的DataStreamJob!

Flink CDC有大佬知道这啥原因吗?这是序列化有问题吗,用的群文件的DataStreamJob

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

Flink CDC有大佬知道这啥原因吗?这是序列化有问题吗,用的群文件的DataStreamJob?

Flink CDC有大佬知道这啥原因吗?这是序列化有问题吗,用的群文件的DataStreamJob

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

Flink CDC中如果是多库多表的 反序列化的时候怎么确定 是属于哪个类的?

Flink CDC中如果是多库多表的 反序列化的时候怎么确定 是属于哪个类的?

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

Flink CDC中我运行官方文档里的datastream api 示例,显示序列化错误,怎么解决?

Flink CDC中我运行官方文档里的datastream api 示例,显示序列化错误,怎么解决?

问答 2023-06-29 来自:开发者社区

Flink CDC中mysql-cdc默认序列化反序列化binlog为debezium json吗?

Flink CDC中mysql-cdc默认序列化反序列化binlog为debezium json吗,可以支持canal json吗?暂时没有接paimon,我是需要从json中获取表的主键以便后续操作,canal json中有pkNames字段,debezuim json中我没发现代码主键的字段,不知道是没有还是我没找到

问答 2023-06-18 来自:开发者社区

Flink CDC自定义的序列化找不到,这个问题有大佬指定是什么原因吗?远程执行的?

Flink CDC自定义的序列化找不到,这个问题有大佬指定是什么原因吗?远程执行的?

问答 2023-06-11 来自:开发者社区

请问 Flink CDC 用API 读取kafka 的json记录,下面脚本报序列化报错,是序列?

请问 Flink CDC 用API 读取kafka 的json记录,下面脚本报序列化报错,是序列化写法不对吗 JsonDeserializationSchema jsonFormat=new JsonDeserializationSchema<>(RuleDetail.class); KafkaSource source = KafkaSource.builder() ...

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

产品推荐

阿里云实时计算Flink

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

+关注