rea-leaf commented on issue #4389:
URL: https://github.com/apache/flink-cdc/issues/4389#issuecomment-4402656599
2026-05-08 09:18:21
org.apache.flink.cdc.runtime.operators.sink.exception.SinkWrapperException:
Failed to handle event DataChangeEvent{tableId=XXX,
before=org.apache.flink.cdc.common.data.binary.BinaryRecordData@db76b101,
after=org.apache.flink.cdc.common.data.binary.BinaryRecordData@94a2bce9,
op=UPDATE, meta=()} in DataSink wrapper.
at
org.apache.flink.cdc.runtime.operators.sink.DataSinkWriterOperator.processElement(DataSinkWriterOperator.java:189)
at
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:75)
at
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:50)
at
org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)
at
org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:37)
at
org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:247)
at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:206)
at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:163)
at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:646)
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:988)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:925)
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:973)
at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:955)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:760)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:569)
at java.base/java.lang.Thread.run(Unknown Source)
Caused by: java.lang.RuntimeException: Could not serialize event
'DataChangeEvent{tableId=XXX,
before=org.apache.flink.cdc.common.data.binary.BinaryRecordData@db76b101,
after=org.apache.flink.cdc.common.data.binary.BinaryRecordData@94a2bce9,
op=UPDATE, meta=()}'.
at
org.apache.flink.cdc.connectors.kafka.json.debezium.DebeziumJsonSerializationSchema.serialize(DebeziumJsonSerializationSchema.java:227)
at
org.apache.flink.cdc.connectors.kafka.json.debezium.DebeziumJsonSerializationSchema.serialize(DebeziumJsonSerializationSchema.java:80)
at
org.apache.flink.cdc.connectors.kafka.sink.PipelineKafkaRecordSerializationSchema.serialize(PipelineKafkaRecordSerializationSchema.java:111)
at
org.apache.flink.cdc.connectors.kafka.sink.PipelineKafkaRecordSerializationSchema.serialize(PipelineKafkaRecordSerializationSchema.java:46)
at
org.apache.flink.cdc.connectors.kafka.shaded.org.apache.flink.connector.kafka.sink.KafkaWriter.write(KafkaWriter.java:170)
at
org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.processElement(SinkWriterOperator.java:184)
at
org.apache.flink.cdc.runtime.operators.sink.DataSinkWriterOperator.processElement(DataSinkWriterOperator.java:187)
... 17 more
Caused by: java.lang.IndexOutOfBoundsException
at
org.apache.flink.core.memory.MemorySegment.getLong(MemorySegment.java:935)
at
org.apache.flink.cdc.common.data.binary.BinarySegmentUtils.getLong(BinarySegmentUtils.java:723)
at
org.apache.flink.cdc.common.data.binary.BinarySegmentUtils.readTimestampData(BinarySegmentUtils.java:1021)
at
org.apache.flink.cdc.common.data.binary.BinaryRecordData.getTimestamp(BinaryRecordData.java:176)
at
org.apache.flink.cdc.connectors.kafka.json.utils.RecordDataConverter.lambda$createFieldGetter$56253627$1(RecordDataConverter.java:366)
at
org.apache.flink.cdc.connectors.kafka.json.utils.RecordDataConverter.lambda$createFieldGetter$babb8b7d$1(RecordDataConverter.java:411)
at
org.apache.flink.cdc.connectors.kafka.json.TableSchemaInfo.getRowDataFromRecordData(TableSchemaInfo.java:85)
at
org.apache.flink.cdc.connectors.kafka.json.debezium.DebeziumJsonSerializationSchema.convertUpdateEventToRowData(DebeziumJsonSerializationSchema.java:406)
at
org.apache.flink.cdc.connectors.kafka.json.debezium.DebeziumJsonSerializationSchema.serialize(DebeziumJsonSerializationSchema.java:220)
... 23 more
--
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]
