[inlong] branch master updated: [INLONG-8808][Sort] Improve convertToBinary for RowDataDebeziumDeserializeSchema (#8809)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 7eab795cc7 [INLONG-8808][Sort] Improve convertToBinary for 
RowDataDebeziumDeserializeSchema (#8809)
7eab795cc7 is described below

commit 7eab795cc7f73ad348222a171adfd760b4c9aff4
Author: Xin Gong <genzhedangd...@gmail.com>
AuthorDate: Mon Aug 28 19:02:58 2023 +0800

    [INLONG-8808][Sort] Improve convertToBinary for 
RowDataDebeziumDeserializeSchema (#8809)
---
 .../cdc/base/debezium/table/RowDataDebeziumDeserializeSchema.java     | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/debezium/table/RowDataDebeziumDeserializeSchema.java
 
b/inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/debezium/table/RowDataDebeziumDeserializeSchema.java
index a9c2a6380e..da3267c2cf 100644
--- 
a/inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/debezium/table/RowDataDebeziumDeserializeSchema.java
+++ 
b/inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/debezium/table/RowDataDebeziumDeserializeSchema.java
@@ -56,6 +56,7 @@ import org.slf4j.LoggerFactory;
 
 import java.math.BigDecimal;
 import java.nio.ByteBuffer;
+import java.nio.charset.StandardCharsets;
 import java.time.Instant;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
@@ -375,6 +376,9 @@ public final class RowDataDebeziumDeserializeSchema 
implements DebeziumDeseriali
                     byte[] bytes = new byte[byteBuffer.remaining()];
                     byteBuffer.get(bytes);
                     return bytes;
+                } else if (dbzObj instanceof String) {
+                    String data = (String) dbzObj;
+                    return data.getBytes(StandardCharsets.UTF_8);
                 } else {
                     throw new UnsupportedOperationException(
                             "Unsupported BYTES value type: " + 
dbzObj.getClass().getSimpleName());