问题一:flink-cdc-connectors 2.3.0 版本引用 flink 1.16.0 ,为何报错
flink-cdc-connectors 2.3.0 版本引用了 flink 1.16.0 是不有bug:
[ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.api.ValidationException: The MySQL server has a timezone offset (0 seconds ahead of UTC) which does not match the configured timezone Asia/Shanghai. Specify the right server-time-zone to avoid inconsistencies for time-related fields.
参考答案:
mysql时间设置没搞好
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/490616?spm=a2c6h.13066369.question.21.4d426d0ch8TtI1
问题二:flink tidb cdc 报错,可能是什么问题呢?flink 版本 1.14.4 cdc
flink tidb cdc 报错,可能是什么问题呢?flink 版本 1.14.4 cdc版本 flink-connector-tidb-cdc-2.3-SNAPSHOT.jar
参考答案:
你这个jar包错了,用flink sql这个包
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/437155?spm=a2c6h.13066369.question.22.4d426d0cXmPL7y
问题三:flink cdc 读取oracle报错,有遇到这种问题的吗
flink cdc 读取oracle报错:
Caused by: java.lang.NoSuchMethodError: io.debezium.config.Field.withType(Lorg/apache/kafka/common/config/ConfigDef$Type;)Lio/debezium/config/Field; at io.debezium.embedded.EmbeddedEngine.(EmbeddedEngine.java:135) at io.debezium.embedded.ConvertingEngineBuilder.(ConvertingEngineBuilder.java:65) at io.debezium.embedded.ConvertingEngineBuilderFactory.builder(ConvertingEngineBuilderFactory.java:26) at io.debezium.engine.DebeziumEngine.create(DebeziumEngine.java:300) at io.debezium.engine.DebeziumEngine.create(DebeziumEngine.java:287) at io.debezium.engine.DebeziumEngine.create(DebeziumEngine.java:273) at com.ververica.cdc.debezium.DebeziumSourceFunction.run(DebeziumSourceFunction.java:409) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:66) at
应该是
io.debezium debezium-connector-oracle 1.9.1.Final
依赖的问题,但是debezium-connector-oracle 2.. 只支持java 11,而目前flink我们用的都是java8,问下各位大佬有遇到这种问题的吗
参考答案:
可以尝试使用debezium-connector-oracle 1.9.1.Final,它支持Java 8。另外,可以尝试更新Flink的依赖,以便使用更新的Debezium版本。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/483497?spm=a2c6h.13066369.question.23.4d426d0c5ZTSi7
问题四:帮忙看下dinky0.7.2+flink1.14.6+flinkcdc2.3.0 报错时区问题 ?
帮忙看下dinky0.7.2+flink1.14.6+flinkcdc2.3.0 cdc SQL方式报错时区问题 ?
参考答案:
source.server-time-zone去掉。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/494810?spm=a2c6h.13066369.question.24.4d426d0ctHT6EK
问题五:如果Flink CDC pgsql库10几分钟更新几千万条数据,复制槽一下子从几十M到几千M,这种情况下如何保证cdc任务不报错,内存不溢出
如果Flink CDC pgsql库10几分钟更新几千万条数据,复制槽一下子从几十M到几千M,这种情况下如何保证cdc任务不报错,内存不溢出
参考答案:
测试内存占用,如果较少增加内存
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/483323?spm=a2c6h.13066369.question.25.4d426d0cqsBgAt