创建好后将刚刚的MySqlTableSourceFactory类原封不动的全部粘贴上去，这样我们从一个.class文件变成了自己的.java文件，再修改成自己想要的connector名，不能和mysql重名，例如我就叫mysql-test-cdc。公司刚入手阿里云的flink，不得不说flink全托管对于简单的数据同步是比较的友好，但是如果是用它来进行flink实时计算，那还是有点小问题，比如底层

阿里云dataworks同步任务流程

通过聚合拆分再聚合的方式实现一行数据变分组的多行多列