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

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

1. 使用DELETE语句：在Flink SQL中，可以直接使用DELETE语句从结果表中删除数据。例如：

DELETE FROM result_table WHERE id IN (SELECT id FROM source_table WHERE data_deleted = '1');

这里，data_deleted是源表中的一个字段，表示数据是否已被删除。如果数据被删除，data_deleted的值为'1'。

1. 使用CREATE OR REPLACE TABLE AS SELECT语句：这种方法会先删除结果表中的所有数据，然后再插入新的数据。例如：

CREATE OR REPLACE TABLE new_result_table AS SELECT * FROM source_table;

然后，将新创建的表替换为原来的结果表：

DROP TABLE result_table;
EXECUTE IMMEDIATE 'ALTER TABLE new_result_table RENAME TO result_table';

注意：以上两种方法都需要确保源表和结果表之间的数据一致性。在实际应用中，可能需要根据具体的需求和数据情况来选择合适的方法。