From 95602f4784f809bf2ed39ac17b562597304084ae Mon Sep 17 00:00:00 2001
From: lanxinxu <48084525+lanxinxu@users.noreply.github.com>
Date: Tue, 18 Jun 2019 14:57:59 +0800
Subject: [PATCH] =?UTF-8?q?=E5=B9=B6=E8=A1=8C=E8=A7=A3=E6=9E=90=E6=A8=A1?=
 =?UTF-8?q?=E5=BC=8F=E4=B8=8B=E6=9C=89=E4=B8=A2=E6=95=B0=E6=8D=AE=E9=A3=8E?=
 =?UTF-8?q?=E9=99=A9=20(#1857)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../canal/parse/inbound/mysql/MysqlMultiStageCoprocessor.java   | 2 ++
 1 file changed, 2 insertions(+)

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 70aba4f1c..5c5ad87a1 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