Skip to content

Commit 2a5828c

Browse files
lzshlzshliuzeshan
and
liuzeshan
authored
[FLINK-35291][runtime] Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme (#3289)
Co-authored-by: liuzeshan <liuzeshan@bytedance.com>
1 parent f24399c commit 2a5828c

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/BinaryRecordDataGenerator.java

+6-6
Original file line numberDiff line numberDiff line change
@@ -58,9 +58,9 @@ public BinaryRecordDataGenerator(DataType[] dataTypes) {
5858
public BinaryRecordDataGenerator(DataType[] dataTypes, TypeSerializer[] serializers) {
5959
checkArgument(
6060
dataTypes.length == serializers.length,
61-
String.format(
62-
"The types and serializers must have the same length. But types is %d and serializers is %d",
63-
dataTypes.length, serializers.length));
61+
"The types and serializers must have the same length. But types is %s and serializers is %s",
62+
dataTypes.length,
63+
serializers.length);
6464

6565
this.dataTypes = dataTypes;
6666
this.serializers = serializers;
@@ -77,9 +77,9 @@ public BinaryRecordDataGenerator(DataType[] dataTypes, TypeSerializer[] serializ
7777
public BinaryRecordData generate(Object[] rowFields) {
7878
checkArgument(
7979
dataTypes.length == rowFields.length,
80-
String.format(
81-
"The types and values must have the same length. But types is %d and values is %d",
82-
dataTypes.length, rowFields.length));
80+
"The types and values must have the same length. But types is %s and values is %s",
81+
dataTypes.length,
82+
rowFields.length);
8383

8484
reuseWriter.reset();
8585
for (int i = 0; i < dataTypes.length; i++) {

0 commit comments

Comments
 (0)