flink-cdc
flink-cdc copied to clipboard
Is it so hard to support Flink1.14.*
Describe the bug(Please use English) Caused by: java.lang.ClassNotFoundException: org.apache.flink.shaded.guava18.com.google.common.util.concurrent.ThreadFactoryBuilder
Environment :
- Flink version : 1.14.5
- Flink CDC version: 2.2.1
unsupported documents can be deleted?

Maybe it's your use problem. I have successfully used version 2.2.1 CDC in flink1.14
Maybe it's your use problem. I have successfully used version 2.2.1 CDC in flink1.14
class com.ververica.cdc.debezium.DebeziumSourceFunction import org.apache.flink.shaded.guava18.com.google.common.util.concurrent.ThreadFactoryBuilder , flink 1.14 do not have guava18,it is guava30,you do not have problem? How to solve this error problem? Thank you,Looking forward to your reply.
I solved the problem like this.
I solved the problem like this.
Could not resolve substitution to a value: ${akka.stream.materializer} cdc:2.3.0
I solved the problem like this.
Could not resolve substitution to a value: ${akka.stream.materializer} cdc:2.3.0 flink :1.15.3