Hi,

2026-07-22 23:00:54,362 INFO  org.apache.flink.cdc.runtime.operators.schema.common.SchemaRegistry [] - Handling evolved schema request: GetEvolvedSchemaRequest{tableId=sbschema.dea_tarmac_flight, schemaVersion=-1}
2026-07-22 23:00:54,366 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Transform:Data -> SchemaOperator -> PrePartition (1/1) (b9d8de1899282a1b56c00c6f3a1f7483_90bea66de1c231edf33913ecd54406c1_0_8) switched from RUNNING to FAILED on postgres-cdc-to-iceberg-flight-taskmanager-1-1 @ 241.140.95.178 (dataPort=42617).
java.io.IOException: Can't get next record for channel InputChannelInfo{gateIdx=0, inputChannelIdx=0}
	at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:106) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.0.jar:1.20.0]
	at java.lang.Thread.run(Unknown Source) ~[?:?]
Caused by: java.io.IOException: Serializer consumed more bytes than the record had. This indicates broken serialization. If you are using custom serialization types (Value or Writable), check their serialization methods. If you are using a Kryo-serialized type, check the corresponding Kryo serializer.
	at org.apache.flink.runtime.io.network.api.serialization.NonSpanningWrapper.readInto(NonSpanningWrapper.java:339) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer.readNonSpanningRecord(SpillingAdaptiveSpanningRecordDeserializer.java:128) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer.readNextRecord(SpillingAdaptiveSpanningRecordDeserializer.java:103) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer.getNextRecord(SpillingAdaptiveSpanningRecordDeserializer.java:93) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:103) ~[flink-dist-1.20.0.jar:1.20.0]
	... 10 more
Caused by: java.lang.IndexOutOfBoundsException
	at org.apache.flink.core.memory.MemorySegment.get(MemorySegment.java:389) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.io.network.api.serialization.NonSpanningWrapper.readByte(NonSpanningWrapper.java:112) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.io.network.api.serialization.NonSpanningWrapper.readBoolean(NonSpanningWrapper.java:107) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.cdc.runtime.serializer.MapSerializer.deserialize(MapSerializer.java:152) ~[flink-cdc-dist-3.6.0.jar:3.6.0]
	at org.apache.flink.cdc.runtime.serializer.MapSerializer.deserialize(MapSerializer.java:43) ~[flink-cdc-dist-3.6.0.jar:3.6.0]
	at org.apache.flink.cdc.runtime.serializer.NullableSerializerWrapper.deserialize(NullableSerializerWrapper.java:91) ~[flink-cdc-dist-3.6.0.jar:3.6.0]
	at org.apache.flink.cdc.runtime.serializer.event.DataChangeEventSerializer.deserialize(DataChangeEventSerializer.java:95) ~[flink-cdc-dist-3.6.0.jar:3.6.0]
	at org.apache.flink.cdc.runtime.serializer.event.DataChangeEventSerializer.deserialize(DataChangeEventSerializer.java:40) ~[flink-cdc-dist-3.6.0.jar:3.6.0]
	at org.apache.flink.cdc.runtime.serializer.event.EventSerializer.deserialize(EventSerializer.java:123) ~[flink-cdc-dist-3.6.0.jar:3.6.0]
	at org.apache.flink.cdc.runtime.serializer.event.EventSerializer.deserialize(EventSerializer.java:39) ~[flink-cdc-dist-3.6.0.jar:3.6.0]
	at org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer.deserialize(StreamElementSerializer.java:206) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer.deserialize(StreamElementSerializer.java:44) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.plugable.NonReusingDeserializationDelegate.read(NonReusingDeserializationDelegate.java:53) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.io.network.api.serialization.NonSpanningWrapper.readInto(NonSpanningWrapper.java:337) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer.readNonSpanningRecord(SpillingAdaptiveSpanningRecordDeserializer.java:128) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer.readNextRecord(SpillingAdaptiveSpanningRecordDeserializer.java:103) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer.getNextRecord(SpillingAdaptiveSpanningRecordDeserializer.java:93) ~[flink-dist-1.20.0.jar:1.20.0]
	at org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:103) ~[flink-dist-1.20.0.jar:1.20.0]
	... 10 more

I am seeing with error when using Flink Postgres CDC. Anyone observed this issue before?

Hi,do you check the same version of flink-cdc's dist and pipepine conenctos?