问题一:Flink CDC从源表插入数据到结果表报一下错误是什么原因?可有解决办法?
Flink CDC从源表插入数据到结果表报一下错误是什么原因?可有解决办法?
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: org.apache.flink.table.connector.source.lookup.cache.LookupCache
参考回答:
缺少 flinksql 依赖jar
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/582245
问题二:Flink CDC源表创建后,查询时报错是什么问题?用的flink1.18?
Flink CDC源表创建后,查询时报错是什么问题?用的flink1.18?
参考回答:
用的上cdc3.0吗,要3.0才支持1.18
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/582200
问题三:Flink CDC这个并行度跟我mysqlid有啥关系呢?
Flink CDC这个并行度跟我mysqlid有啥关系呢?Caused by: java.lang.IllegalArgumentException: Subtask ID 3 is out of server id range 1, please adjust the server id range to make the number of server id larger than the source parallelism.
参考回答:
并行度一定要小于等于server-id的范围
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/582167
问题四:Flink CDC这个报错信息 是缺少这包包的类 ?
Flink CDC这个报错信息 是缺少这包包的类 ?
参考回答:
pipeline连接器不需要以前的那些包的, https://ververica.github.io/flink-cdc-connectors/master/content/%E5%BF%AB%E9%80%9F%E4%B8%8A%E6%89%8B/mysql-starrocks-pipeline-tutorial-zh.html 这个官网案例
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/582165
问题五:使用flinkcdc 3.0 启动 放在lib下面了。 还缺少啥jar包呢?
使用flinkcdc 3.0 启动 bash bin/flink-cdc.sh mysql-starrocks.yaml ,报错如图。我也把MySQL pipeline connector 3.0.0 和 StarRocks pipeline connector 3.0.0 放在lib下面了。 还缺少啥jar包呢?
参考回答:
jar包不是放在flink集群的,放在3.0的解压目录的lib文件夹,加上这个
少了这个 flink-connector-mysql-cdc-3.0.0.ja报错有提示的哦
关于本问题的更多回答可点击原文查看: