chenrenfei commented on issue #3942: URL: https://github.com/apache/flink-cdc/issues/3942#issuecomment-2709938081
在flink-cdc同步业务数据库数据到数仓过程中,业务数据库会经常进行归档删除操作,但数仓的同步则需要区分归档删除和常规的业务删除,因此我们给流水表统一设计了:archivement_period(归档周期)字段,当该字段的值不为null时,希望删除操作flink-cdc过滤掉,逻辑即: 归档字段:archivement_period 或 is_archived 不为null,则过滤掉delete操作 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
