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

flink cdc source mysql sink kafka 报包冲突 如何解决?

问题1:flink cdc source mysql sink kafka 报包冲突 如何解决?问题2:这个也看不出问题。我cdc 2.4 flink 1.13.6

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

请问flink cdc中有没有demo,说下怎么改写sink映射类的?

请问flink cdc中有没有demo,说下怎么改写sink映射类的?还是说,只能自己看源码,找到对应的sink映射类去看。

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

flink cdc 整库同步MySQL 如何写入hudi,sink hudi的代码该如何写?

flink cdc 整库同步MySQL 如何写入hudi,sink hudi的代码该如何写?

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

flink cdc中我在sink 那里添加 holoJDBCWriter 报错了,什么原因?

flink cdc中我在sink 那里添加 holoJDBCWriter 报错了,我看报找不到的类在 flink-core 里能找到,什么原因?感觉像是jar包冲突了。

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

Flink CDC sink iceberg遇过这个问题吗?这个路径没错的,但这个表是 hive

Flink CDC sink iceberg遇过这个问题吗?这个路径没错的,但这个表是 hive catlog表

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

问题1:flink cdc 多表同步 通过stream api 获取数据 再写入多个sink表?

问题1:flink cdc 多表同步 1 通过stream api 获取数据 再写入多个sink表 2 写多个flinkSql 的source表,多个sink表 这两种方式哪个比较推荐? 问题2:二种要更消耗资源吗?现在已经有第二种实现,但是不晓得对资源消耗情况咋样

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

大家好, Flink CDC中Mysql ->postgre 同步, 源端10个字段,Sink端?

大家好, Flink CDC中Mysql ->postgre 同步, 源端10个字段,Sink端10个字段, 但新建Finksql 时只建9个字段, 未匹配字段Flink 也会进行类型匹配检查并且如果不一致 会异常, 这块有什么解决办法吗, 想只检查进行匹配字段的类型?

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

Flink CDC Sink到Redis是没有实现两阶段提交的吗?

Flink CDC Sink到Redis是没有实现两阶段提交的吗我用自定义写的

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

Flink CDC是如何保证Source端与Sink的数据一致性?

Flink CDC是如何保证Source端与Sink的数据一致性?

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

flink cdc 有少量数据没同步过来?多表join,有个表的字段变更了,这边没同步到sink表

flink cdc 有少量数据没同步过来?多表join,有个表的字段变更了,这边没同步到sink表

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

产品推荐

阿里云实时计算Flink

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

+关注