请问基于StarRocksSink、flinkcdc、flink stream api怎么处理业务系统删除的数据和DDL操作?