自己写个自定义agg函数把,此回答整理自钉群“Flink CDC 社区”