diff --git a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RowsLogBuffer.java b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RowsLogBuffer.java index 34105e31..a2c58493 100644 --- a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RowsLogBuffer.java +++ b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RowsLogBuffer.java @@ -957,11 +957,10 @@ public final class RowsLogBuffer { jsonValue.toJsonString(builder); value = builder.toString(); buffer.position(position + len); - // byte[] binary = new byte[len]; // buffer.fillBytes(binary, 0, len); // value = binary; - javaType = Types.VARBINARY; + javaType = Types.VARCHAR; length = len; break; }