MOBIN-F opened a new pull request, #3784:
URL: https://github.com/apache/flink-cdc/pull/3784
pipeline.yml
```
source:
type: mysql
name: MySQL Source
hostname: localhost
port: 3306
username: test
password: test
tables: testDB.testTable
server-id: 5206
server-time-zone: Asia/Shanghai
sink:
type: kafka
name: Kafka Sink
properties.bootstrap.servers: localhost:9092
topic: test_topic
pipeline:
name: MySQL to Kafka Pipeline
parallelism: 1
```
```
Caused by: java.lang.NoSuchMethodError: 'void
org.apache.flink.formats.json.JsonRowDataSerializationSchema.<init>(org.apache.flink.table.types.logical.RowType,
org.apache.flink.formats.common.TimestampFormat,
org.apache.flink.formats.json.JsonFormatOptions$MapNullKeyMode,
java.lang.String, boolean)'
at
org.apache.flink.cdc.connectors.kafka.serialization.JsonSerializationSchema.buildSerializationForPrimaryKey(JsonSerializationSchema.java:134)
at
org.apache.flink.cdc.connectors.kafka.serialization.JsonSerializationSchema.serialize(JsonSerializationSchema.java:101)
at
org.apache.flink.cdc.connectors.kafka.serialization.JsonSerializationSchema.serialize(JsonSerializationSchema.java:47)
at
org.apache.flink.cdc.connectors.kafka.sink.PipelineKafkaRecordSerializationSchema.serialize(PipelineKafkaRecordSerializationSchema.java:99)
at
org.apache.flink.cdc.connectors.kafka.sink.PipelineKafkaRecordSerializationSchema.serialize(PipelineKafkaRecordSerializationSchema.java:44)
```
In flink>=1.20, the constructor of JsonRowDataSerializationSchema has 6
parameters, and in flink<1.20, the constructor of
JsonRowDataSerializationSchema has 5 parameters.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
