Skip to content

Commit e6bb8e9

Browse files
authored
[hotfix][cdc-rumtime][minor] Clean up useless code in BinaryRecordDataSerializer (#2845)
Co-authored-by: xuyu <11161569@vivo.com>
1 parent f2c0a03 commit e6bb8e9

1 file changed

Lines changed: 0 additions & 1 deletion

File tree

flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/data/binary/BinaryRecordDataSerializer.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,6 @@ public BinaryRecordData deserialize(BinaryRecordData reuse, DataInputView source
9696
segments == null || (segments.length == 1 && reuse.getOffset() == 0),
9797
"Reuse BinaryRecordData should have no segments or only one segment and offset start at 0.");
9898

99-
int arity = source.readInt();
10099
int length = source.readInt();
101100
if (segments == null || segments[0].size() < length) {
102101
segments = new MemorySegment[] {MemorySegmentFactory.wrap(new byte[length])};

0 commit comments

Comments
 (0)