flink sql多条cdc数据流实时regular join如何减少作业状态？

[casel.chen]

当前flink实时作业接的kafka canal json格式的cdc数据，mysql表会有新增和更新数据，但不会有物理删除。
如果直接多条cdc数据流实时关联会导致作业状态很大，请教:
1. 有没有什么办法可以减少作业状态？
2. cdc格式的retract流可以加去重变成append流吗？
3. 使用append流多流关联是不是能减少作业状态？