问题一:我想问一下,我用的是flink mysql cdc2.3.0,这个效果怎么做?
我想问一下,我用的是flink mysql cdc2.3.0,这个效果怎么做?
参考回答:
需要开启动态加表参数,启动方式不要更换。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/609936
问题二:Flink CDC里这个问题怎么解决?
Flink CDC里这个问题怎么解决?
参考回答:
断点重启加资源。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/609928
问题三:Flink CDC任务取消后,这里jvm metaspace不回收为什么?
Flink CDC任务取消后,这里jvm metaspace不回收为什么?
参考回答:
有引用持有,导致类加载器不能释放,不能被GC。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/609924
问题四:Flink CDC里mysql->doris,报错 ,这个什么原因?
Flink CDC里mysql->doris,报错 ,这个什么原因?
参考回答:
太多被过滤的列,应该是某些原因导致数据无法插入doris。看一下这个地址里的内容 doris、starocks的字符串的长度和mysql的不一样,一般是doris、starocks最好按照mysql字段的3倍长度来建表。doris/starrocks. VARCHAR(n)
a. 变长字符串,长度范围为:1-65533 字节长度,以 UTF-8 编码存储的,因此通常英文字符占 1 个字节,中文字符占 3 个字节。这里的n指的是字节数
MySQL中varchar(n)表示n个字符,无论汉字和英文。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/609923
问题五:大佬们Flink CDC里 GC的这个问题 怎么解决?
大佬们Flink CDC里 GC的这个问题 怎么解决?
参考回答:
要及时关闭链接,jvm的内存调整。flink的启动参数上调,网上搜搜。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/609922