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

对于Flink CDC,可以通过两个source一个监听insert 一个监听update 可以嘛?

对于Flink CDC,可以通过两个source一个监听insert 一个监听update 这样可以吗?

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

对于Flink CDC,把insert和update 拆分开处理,有什么好的方法处理吗?

对于Flink CDC,现在flink程序监听一个表的insert和update事件,但是由于update的变更量过大导致insert有延迟的情况,我现在想要把insert和update 拆分开处理,有什么好的方法处理吗?

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

flink cdc在insert的时候为什么会有do update?

flink cdc在insert的时候为什么会有do update?能取消这个do update,到分布式数据库吗?

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

Flink中canal-json那个binlog的type怎么能过滤出insert和update?

Flink中canal-json 那个binlog的type怎么能过滤出insert和update的呀?

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

Flink CDC如何只取里面的INSERT和UPDATE操作,或者这么可以不回撤?

Flink CDC用FlinkSQL 接Canal Json 如何只取里面的INSERT和UPDATE操作,或者这么可以不回撤?因为我sink是ES,当回撤的时候,会先通过主键删除,导致再写入的时候,数据不完整了,如何可以避免这种通过主键删除的问题?

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

Flink CDC表的TTL对删除不起作用吗,只对insert 、update起作用?

Flink CDC表的TTL对删除不起作用吗,只对insert 、update起作用?

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

flink cdc能在source端过滤数据吗?过滤掉insert,和update,只想要delet

flink cdc能在source端过滤数据吗?过滤掉insert,和update,只想要delete操作。

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

请问大家用Flink CDC创建iceberg表 只能insert不能update和delete?

请问大家用Flink CDC创建iceberg表 只能insert不能update和delete 怎么解决啊?

问答 2022-07-11 来自:开发者社区

flink cdc 的sql作业里面能获取到当前的记录是要 insert 还是 update 还是

flink cdc 的sql作业里面能获取到当前的记录是要 insert 还是 update 还是 delete 吗,比如有某个默认字段记录了这些信息,我们可以根据不同的操作类型做不同的逻辑 比如只要insert事件,过滤掉delete事件之类的

问答 2021-12-02 来自:开发者社区

Flink SQL 不支持 INSERT INTO… ON DUPLICATE KEY UPDATE

你好,我们用的1.11版本。 需求:table t 有三个字段(a,b,c) 我们的场景只想根据主键a更新部分字段b,其余的字段c原有的值保持不变, 例如mysql 支持: insert into t(a,b) select 1,2 on duplicate key update b=2; 主键重复的时候只更新字段b,字段c的值不变。 但是flink sql 目前只支...

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注