fix binary field converting

apache · May 30, 2023 · 12c0dbf · 12c0dbf
1 parent 648e302
commit 12c0dbf
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...nbase-cdc/src/main/java/com/ververica/cdc/connectors/oceanbase/table/OceanBaseRecord.java b/...nbase-cdc/src/main/java/com/ververica/cdc/connectors/oceanbase/table/OceanBaseRecord.java
@@ -19,6 +19,7 @@
 import com.oceanbase.oms.logmessage.DataMessage;
 
 import java.io.Serializable;
+import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -66,7 +67,11 @@ private String getFieldStringValue(DataMessage.Record.Field field) {
         if (field.getValue() == null) {
             return null;
         }
-        return field.getValue().toString(field.getEncoding());
+        String encoding = field.getEncoding();
+        if ("binary".equalsIgnoreCase(encoding)) {
+            return Arrays.toString(field.getValue().getBytes());
+        }
+        return field.getValue().toString(encoding);
     }
 
     public SourceInfo getSourceInfo() {