Skip to content

Commit

Permalink
[connector] FlinkRowToFlussRowConverter should convert VARCHAR withou…
Browse files Browse the repository at this point in the history
…t de/encoding (alibaba#226)

This closes alibaba#255
  • Loading branch information
loserwang1024 authored and sunxiaojian committed Dec 24, 2024
1 parent d81ca53 commit 9aeae08
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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) -> {
Expand Down

0 comments on commit 9aeae08

Please sign in to comment.