This is an automated email from the ASF dual-hosted git repository.
ruanhang1993 pushed a commit to branch release-3.2
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/release-3.2 by this push:
new 203bb9211 [FLINK-35291][runtime] Improve the ROW data deserialization
performance of DebeziumEventDeserializationScheme (#3289) (#3670)
203bb9211 is described below
commit 203bb9211b717e5a5df0a9b190815e95e4c9def2
Author: Kunni <[email protected]>
AuthorDate: Wed Nov 20 15:37:56 2024 +0800
[FLINK-35291][runtime] Improve the ROW data deserialization performance of
DebeziumEventDeserializationScheme (#3289) (#3670)
Co-authored-by: liuzeshan <[email protected]>
Co-authored-by: lzshlzsh <[email protected]>
---
.../cdc/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++) {
