diff --git a/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/utils/FlinkRowToFlussRowConverter.java b/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/utils/FlinkRowToFlussRowConverter.java index 3bed9b62..aa755a39 100644 --- a/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/utils/FlinkRowToFlussRowConverter.java +++ b/fluss-connectors/fluss-connector-flink/src/main/java/com/alibaba/fluss/connector/flink/utils/FlinkRowToFlussRowConverter.java @@ -142,7 +142,7 @@ private FlussSerializationConverter createInternalConverter(LogicalType flinkDat case VARCHAR: return (flinkField) -> { StringData stringData = (StringData) flinkField; - return BinaryString.fromString(stringData.toString()); + return BinaryString.fromBytes(stringData.toBytes()); }; case DECIMAL: return (flinkField) -> {