[cdc-connector][db2] fix UT

apache · Dec 14, 2023 · 91b96f5 · 91b96f5
1 parent 4535050
commit 91b96f5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ain/java/com/ververica/cdc/runtime/serializer/data/binary/BinaryRecordDataSerializer.java b/...ain/java/com/ververica/cdc/runtime/serializer/data/binary/BinaryRecordDataSerializer.java
@@ -95,7 +95,7 @@ public BinaryRecordData deserialize(BinaryRecordData reuse, DataInputView source
         checkArgument(
                 segments == null || (segments.length == 1 && reuse.getOffset() == 0),
                 "Reuse BinaryRecordData should have no segments or only one segment and offset start at 0.");
-
+        source.readInt();
         int length = source.readInt();
         if (segments == null || segments[0].size() < length) {
             segments = new MemorySegment[] {MemorySegmentFactory.wrap(new byte[length])};