[changelog] fix changelog-deserialize exception message typo.

pull/328/head
wangminchao 4 years ago committed by Leonard Xu
parent 8f58a0cbdd
commit ee6c345cbb

@ -90,7 +90,7 @@ public class ChangelogJsonDeserializationSchema implements DeserializationSchema
// a big try catch to protect the processing. // a big try catch to protect the processing.
if (!ignoreParseErrors) { if (!ignoreParseErrors) {
throw new IOException( throw new IOException(
format("Corrupt Debezium JSON message '%s'.", new String(bytes)), t); format("Corrupt Changelog JSON message '%s'.", new String(bytes)), t);
} }
} }
} }

Loading…
Cancel
Save