请问Flink这种情况下有is_delete处理方案么？

可以采取以下方案处理Flink CDC与Hudi中is_delete软删除字段：

存量数据同步（+I模式）：
当使用CDC同步已有数据时，is_delete为0的数据会被正常同步到Hudi表。

实时同步（-U +U模式）：
当is_delete从0变1时，Flink CDC应捕获到这两个变更事件。在Flink SQL中，您可以创建一个视图或者在DWD层处理这些变更，将-U和+U合并为一个UPDATE事件，更新is_delete字段为1。

-- 假设event_time是时间戳字段

CREATE VIEW updated_records AS
SELECT * FROM (
  SELECT *, ROW_NUMBER() OVER(PARTITION BY id ORDER BY event_time DESC) as row_num
  FROM cdc_source_table
) WHERE row_num = 1 AND is_delete = 1;

然后使用updated_records视图进行后续的DWD、DIM、DWS和ADS层的计算。可以看下这个文档

自己写逻辑直接修改row_kind，用api不用sql ，此回答整理自钉群“【②群】Apache Flink China社区”