并行解析模式下有丢数据风险 (#1857)

alibaba · Jun 18, 2019 · 95602f4 · 95602f4
1 parent 058e1fc
commit 95602f4
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlMultiStageCoprocessor.java b/...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