Skip to content

Commit e1ddbd3

Browse files
author
wangminchao
committed
[changelog] fix typo changelog-deserialize exception message.
1 parent e992f27 commit e1ddbd3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-format-changelog-json/src/main/java/com/ververica/cdc/formats/json/ChangelogJsonDeserializationSchema.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ public void deserialize(byte[] bytes, Collector<RowData> out) throws IOException
9090
// a big try catch to protect the processing.
9191
if (!ignoreParseErrors) {
9292
throw new IOException(
93-
format("Corrupt Debezium JSON message '%s'.", new String(bytes)), t);
93+
format("Corrupt Changelog JSON message '%s'.", new String(bytes)), t);
9494
}
9595
}
9696
}

0 commit comments

Comments
 (0)