Skip to content

Commit dfd66cd

Browse files
committed
fix
1 parent 27cfdd6 commit dfd66cd

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/com/zendesk/maxwell/schema/columndef/JsonColumnDef.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@ public Object asJSON(Object value, MaxwellOutputConfig config) throws ColumnDefC
2626
try {
2727
byte[] bytes = (byte[]) value;
2828
if (bytes.length > 4096) {
29-
LOGGER.warn("Parsing JSON over limit for field: " + name);
30-
jsonString = JsonBinary.parseAsString(bytes);
29+
LOGGER.warn("Skipping JSON over limit for field: " + name);
30+
jsonString = "null";
3131
} else {
3232
jsonString = bytes.length > 0 ? JsonBinary.parseAsString(bytes) : "null";
3333
}

0 commit comments

Comments
 (0)