From 203bb9211b717e5a5df0a9b190815e95e4c9def2 Mon Sep 17 00:00:00 2001 From: Kunni Date: Wed, 20 Nov 2024 15:37:56 +0800 Subject: [PATCH] [FLINK-35291][runtime] Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme (#3289) (#3670) Co-authored-by: liuzeshan Co-authored-by: lzshlzsh --- .../runtime/typeutils/BinaryRecordDataGenerator.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataGenerator.java b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataGenerator.java index bb7559109..5004fa4f2 100644 --- a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataGenerator.java +++ b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataGenerator.java @@ -58,9 +58,9 @@ public class BinaryRecordDataGenerator { public BinaryRecordDataGenerator(DataType[] dataTypes, TypeSerializer[] serializers) { checkArgument( dataTypes.length == serializers.length, - String.format( - "The types and serializers must have the same length. But types is %d and serializers is %d", - dataTypes.length, serializers.length)); + "The types and serializers must have the same length. But types is %s and serializers is %s", + dataTypes.length, + serializers.length); this.dataTypes = dataTypes; this.serializers = serializers; @@ -77,9 +77,9 @@ public class BinaryRecordDataGenerator { public BinaryRecordData generate(Object[] rowFields) { checkArgument( dataTypes.length == rowFields.length, - String.format( - "The types and values must have the same length. But types is %d and values is %d", - dataTypes.length, rowFields.length)); + "The types and values must have the same length. But types is %s and values is %s", + dataTypes.length, + rowFields.length); reuseWriter.reset(); for (int i = 0; i < dataTypes.length; i++) {