[changelog] fix changelog-deserialize exception message typo.

pull/320/head
wangminchao 4 years ago committed by Leonard Xu
parent e4763adbc2
commit ba83bafb0b

@ -90,7 +90,7 @@ public class ChangelogJsonDeserializationSchema implements DeserializationSchema
// a big try catch to protect the processing.
if (!ignoreParseErrors) {
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