diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlMultiStageCoprocessor.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlMultiStageCoprocessor.java index 70aba4f1ce..5c5ad87a1e 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlMultiStageCoprocessor.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlMultiStageCoprocessor.java @@ -441,6 +441,8 @@ class SimpleFatalExceptionHandler implements ExceptionHandler { @Override public void handleEventException(final Throwable ex, final long sequence, final Object event) { + //异常上抛,否则processEvents的逻辑会默认会mark为成功执行,有丢数据风险 + throw new CanalParseException(ex); } @Override