LvYanquan created FLINK-36211:
---------------------------------
Summary: Shade kafka related package in Kafka Pipeline connector.
Key: FLINK-36211
URL: https://issues.apache.org/jira/browse/FLINK-36211
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cassandra-3.2.0
Reporter: LvYanquan
Fix For: cdc-3.2.0
An issue reported from slack:
I'm trying to create a Flink CDC pipeline from MySql to Kafka (Flink CDC 3.1.1,
Flink 1.18). When I try to submit the yaml file the job starts but then fails
with error:
{{{}Caused by: java.lang.NoSuchMethodError: 'void
org.apache.flink.streaming.connectors.kafka.internals.metrics.KafkaMetricMutableWrapper.<init>({}}}{{{}[org.apache.flink.cdc.connectors.kafka.shaded.org|http://org.apache.flink.cdc.connectors.kafka.shaded.org/]{}}}{{{}.apache.kafka.common.Metric)'{}}}
we should shade {{org.apache.flink.streaming.connectors.kafka to avoid conflict
with flink-connector-kafka.}}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
