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

Flink使用Elasticsearch作为结果表怎么删除数据

Flink使用Elasticsearch作为结果表怎么删除数据

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

flink cdc 源表删除数据后 目标表没删除

sink表由两张表关联而来,dw_station_info数据主要来源于dw_gas_station_info,主键都是id,删除dw_gas_station_info数据后,dw_station_info数据怎么同步删除呢?

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

FlinkCDC对于删除数据,flink前面对加-D,+U,-U等状态,我这边可以拿到写库?

FlinkCDC对于删除数据,flink前面对加-D,+U,-U等状态,我这边可以拿到写(前面的状态)库吗?开源flink 也支持吧

文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之JDBC连接器实时同步的时候如何删除数据吗

问题一:Flink CDC 里指定时间戳启动,时间戳到当前时间中发生的事件都是read事件吗? Flink CDC 里指定时间戳启动,时间戳到当前时间中发生的事件都是read事件吗? 参考答案: 在Flink CDC(Continuous Data Capture)中,指定时间戳启动意味着从该时间点开始消费变更数据。这个时间点之后发生的数据库变更事件会...

文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之delete主键删除源表一条记录,目标表未删除数据问题如何解决

问题一:flink cdc delete主键删除源表一条记录,目标表未删除数据问题 flink cdc delete源表,目标表未删除, 如下: INSERT INTO sink_table ( id, device_id, name, device_type, device_name, gateway_seria...

实时计算 Flink版产品使用合集之delete主键删除源表一条记录,目标表未删除数据问题如何解决
问答 2024-05-07 来自:开发者社区

Flink CDC里mysqlcdc ->doris删除数据没生效是什么原因?

Flink CDC里mysqlcdc ->doris删除数据没生效是什么原因?doris是unique的表,但是没删数据成功。

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

Flink有没有人用过JDBC连接器sink的时候删除数据?

Flink有没有人用过JDBC连接器sink的时候删除数据,我找了半天没看到有指定op的参数,JDBC连接器实时同步的时候支持删除数据吗?

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

Flink CDC入湖入仓过程中是如何区分上游业务表删除数据的?

Flink CDC入湖入仓过程中是如何区分上游业务表删除数据的?因为有的业务本身需要删除数据,有的是因为数据库归档删除数据,这二者怎么区分?业务删除数据要在目标paimon表上删除数据的,但归档删除数据是需要忽略的?

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

Flink CDC这么多union。如果数据库删除数据,能正常把删除的同步过去吗?

Flink CDC这么多union。然后再和jdbc关联,如果数据库删除数据,能正常把删除的同步过去吗?

问答 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.....

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

产品推荐

实时计算 Flink

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

+关注