问题一:flink cdc启动时候报错线程不够 可以通过什么方式解决吗
flink cdc启动时候报错线程不够 可以通过什么方式解决吗
参考答案:
貌似不是线程不够 是线程的size 直接为0了
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/455034?spm=a2c6h.13066369.question.41.4d426d0cWsp2jO
问题二:对于Flink CDC,pom文件(最外层的和这个模块的)明明已经没有blink了,为啥还报错?
对于Flink CDC,pom文件(最外层的和这个模块的)明明已经没有blink了,为啥编译还会爆这个错误呢?
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/482468?spm=a2c6h.13066369.question.44.4d426d0cAjTiip
问题三:flink-cdc 链接mysql时候serverTimeZone正常,为什么制定上海就报错?
flink-cdc 链接mysql时候serverTimeZone("UTC")正常,制定上海就报错,这种数据库怎么更改呢? The MySQL server has a timezone offset (0 seconds ahead of UTC) which does not match the configured timezone GMT+08:00. Specify the right server-time-zone to avoid inconsistencies for time-related fields.
参考答案:
mysql和flink的时间要一致吧
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/484559?spm=a2c6h.13066369.question.43.4d426d0c7gAHfc
问题四:在使用flink-connector-mysql-cdc 2.3.0的时候报错为什么啊?
在使用flink-connector-mysql-cdc 2.3.0的时候报错为什么啊?只有一个MySQL 8.0.27的包Caused by : java.lang.NoSuchMethodError:com.mysql.cj.CharsetMapping.getStaticJavaEncodingForMysqlCharset
at io.debezium.connector.mysql.MySqlValueConverters$CharsetMappingWrapper.getJavaEncodingForMysql......
参考答案:
是不是没有导入flink-sql-connector-mysql的包,放在集群上的lib目录下面,idea开发直接maven导包。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/485852?spm=a2c6h.13066369.question.44.4d426d0cxJUIM8
问题五:flink cdc 2.3, flink 1.16.0 这个异常如何解决?
flink cdc 2.3, flink 1.16.0 这个异常如何解决?为啥本地没问题,提交到yarn就报错 java.lang.NoClassDefFoundError: Could not initialize class io.debezium.embedded.EmbeddedEngine$EmbeddedConfig
参考答案:
看一下是不是maven依赖冲突导致的,EmbeddedConfig 保留有这个的
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/480089?spm=a2c6h.13066369.question.47.4d426d0cSS3UnS