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

flink cdc delete主键删除源表,目标表未删除数据问题

flink cdc delete源表,目标表未删除,如下:INSERT INTO sink_table (id,device_id,name,device_type,device_name,gateway_serial_num,points_model_id,device_uniq_code,etl_time)SELECTt1.id,t1.device_id,t2.device_type,t2.....

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

flink cdc delete源表,目标表未删除

flink cdc delete源表,目标表未删除,如下:INSERT INTO sink_table ( id, device_id, name, device_type, device_name, gateway_serial_num, points_model_id, device_uniq_code, etl_time)SELECT ...

问答 2023-10-31 来自:开发者社区

Flink CDC在一个Job里,如果有多个源表,有什么办法公用一个server-id不?

Flink CDC在一个Job里,如果有多个源表,有什么办法公用一个server-id不。一个SQL有多个源表,会建立多个binlog Dump....多了 会吧MySQL搞死?

问答 2023-10-31 来自:开发者社区

Flink CDC如果源表有数据新增或修改时,新增或修改的数据不会同步有没有解决办法?

Flink CDC中pgsql在全量同步阶段,如果源表有数据新增或修改时,新增或修改的数据不会同步有没有解决办法?

文章 2023-10-25 来自:开发者社区

对于Flink CDC,当源表的数据被删除后,可以通过以下方法在结果表中同步删除

对于Flink CDC,当源表的数据被删除后,可以通过以下方法在结果表中同步删除: 使用DELETE语句:在Flink SQL中,可以直接使用DELETE语句从结果表中删除数据。例如: DELETE FROM result_table WHERE id IN (SELECT id FROM source_tabl...

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

Flink CDC 源表数据删了。结果表有什么办法也同步删除?

Flink CDC 源表数据删了。结果表有什么办法也同步删除?用的Flink SQL来执行INSERT INTO ====

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

Flink CDC尝试使用维表join,如果是源表数据变更,怎么解决维表数据变化也输出结果的呢?

Flink CDC尝试使用维表join,如果是源表数据变更,可以输出聚合数据,如果是维表数据变更就没有数据输出了,你们是怎么解决维表数据变化也输出结果的呢?

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

flink sql任务有三个mysql cdc 源表通过left join关联写入目标表,没更新?

flink sql任务有三个mysql cdc 源表通过left join关联写入目标表。过了半天之后,更新源表中的记录,发现目标表没更新。这是flink SQL不支持吗,还是要做什么特殊设置,或者使用什么语法?就是更新了where条件对应的记录,另外,大表join,是如何做实时记录匹配的,应该是需要流内存拦截吧,不然怎么做到实时匹配呢?假如关联的两张表的记录一个在最开始就来了,另一个迟了很久才....

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

Flink CDC中这种cdc全量采集的时候监控源表这个反压百分100,是因为我的MySQL太慢了?

Flink CDC中这种cdc全量采集的时候,监控源表这个反压百分100,是因为我的MySQL太慢了吗?

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

大佬,Flink CDC这个问题遇到过吗,源表1亿条数据,全量数据阶段卡住了感觉?

大佬,Flink CDC这个问题遇到过吗,源表1亿条数据,全量数据阶段卡住了感觉?

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

产品推荐

阿里云实时计算Flink

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

+关注