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

各位大佬,Flink CDC 中有没有postgreSQL的sink,支持upsert 的demo?

各位大佬,Flink CDC 中有没有postgreSQL的sink,支持upsert 的demo,有的麻烦艾特我一下?

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

大佬们,求问一下flink cdc sink到iceberg 上游ddl怎么同步到下游哇,目前看?

大佬们,求问一下flink cdc sink到iceberg 上游ddl怎么同步到下游哇,目前看iceberg文档不支持flink sql的alter table?

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

Flink CDC中怎么让sink并行度和source不一样?flink sql?

Flink CDC中怎么让sink并行度和source不一样?flink sql?

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

大佬们,Flink CDC中sink表不支持upsert语法怎么处理?pg9.4版本不支持

大佬们,Flink CDC中sink表不支持upsert语法怎么处理?pg9.4版本不支持

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

老哥们 请教一个Flink CDC 问题,使用了lookup join 过后 sink不输出数据,也

老哥们 请教一个Flink CDC 问题,使用了lookup join 过后 sink不输出数据,也没报错 一般是什么原因呢? select 又能查到数据 ,去掉lookup join 就可以了

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

大佬请教个问题,就是上次我说的flink cdc source mysql sink hudi,时

大佬请教个问题,就是上次我说的flink cdc source mysql sink hudi,时差多了八个小时,当时让我看MySQL的时区是Asia/Shanghai (CST,+0800)? 就是有个问题是,我这边有两个业务库,时区都是一样的,只有这个同步过来时区+8小时,另外的那个是正常的,这个是什么原因?我这样加 不对,正确的如何加呀?

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

Flink CDC这都是默认配置吧,sink表总数一直没变过了,估计卡住了

Flink CDC这都是默认配置吧,sink表总数一直没变过了,估计卡住了

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

大佬能看下Flink CDC这个源表更新或者插入数据sink表为啥没有更新啊

大佬能看下Flink CDC这个源表更新或者插入数据sink表为啥没有更新啊 本地测试需要开checkpoint吗,是row格式的,不需要设置checkpoint,我百度设置'debezium.snapshot.mode' = 'initial' 就行了,这个参数好像需要设置,为啥这个参数影响这么大呢,怎么设置先全量,然后再增量呢,我现在有个场景,有100张表,我想先用spark或者presto....

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

Flink CDC 中sink到es没有指定主键,是不是每次都会新增数据?

Flink CDC 中sink到es没有指定主键,是不是每次都会新增数据?

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

大家有没有FLink CDC MySQL自定义sink 成json 数据输出出去的资料吗? 或者si

大家有没有FLink CDC MySQL自定义sink 成json 数据输出出去的资料吗? 或者sink到Redis?

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

产品推荐

阿里云实时计算Flink

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

+关注