问题一：在Flink CDC中MySQL采集时出现字段变更时报错，3.1.1是还不支持吗？
在Flink CDC中MySQL采集时出现字段变更时报错，3.1.1是还不支持吗？Caused by: java.lang.RuntimeException: Failed to schema change, AlterColumnTypeEvent{tableId=ods.ods_jboot2_sys_coach_class_fees, nameMapping={price=DECIMAL(10, 2) NOT NULL}}, reason: Unsupported schema change event, AlterColumnTypeEvent{tableId=ods.ods_jboot2_sys_coach_class_fees, nameMapping={price=DECIMAL(10, 2) NOT NULL}}
参考答案：
下游是 Doris 吗？目前 Doris 还不支持列类型变更，预计下个版本会加入。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/657844
问题二：在Flink CDC中flink版本1.15，写入kafka报错，如何解决？
在Flink CDC中flink版本1.15，写入kafka报错，如何解决？请参考图片： 
参考答案：
这个包给删了，重启下集群。请参考图片： 
。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/657816
问题三：在Flink CDC中写的同步任务，运行一段时间之后就出现下面的错误，请问这是什么原因？
在Flink CDC中写的同步任务，运行一段时间之后就出现下面的错误，请问这是什么原因？请参考图片： 
参考答案：
java.lang.NoClassDefFoundError这个错误通常表示在编译时存在某个类，但在运行时却找不到该类,在这个特定的情况下，错误消息指出缺少了 com.ververica/cdc/commons/util/StringUtils 类。这可能意味着：您的应用程序依赖于一个未包含在 classpath 中的库（即 com.ververica/cdc/commons）。
可能是由于版本不匹配导致的冲突：应用程序使用了一个与运行环境中的其他组件不同的版本。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/657808
问题四：在Flink CDC中是不是应该自定义实体用于后面sink的时候分别addsink？
在Flink CDC中使用datastreamapi SourceFunction读取了pg两张表，表结构不一样，是不是应该自定义实体用于后面sink的时候分别addsink？请参考图片: 
参考答案：
没有，现在的sink基本都是多sink 。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/657817
问题五：在Flink CDC中如图所示这是属于正则不生效吗？
在Flink CDC中如图所示这是属于正则不生效吗？请参考图片： 
参考答案：
找个正则表达式检验下你就知道你写的对不对。
关于本问题的更多回答可点击进行查看：
