diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java index 59fa2839..6b34edf5 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java @@ -191,6 +191,9 @@ public abstract class AbstractEventParser extends AbstractCanalLifeCycle } catch (TableIdNotFoundException e) { throw e; } catch (Throwable e) { + if (e.getCause() instanceof TableIdNotFoundException) { + throw (TableIdNotFoundException) e.getCause(); + } // 记录一下,出错的位点信息 processSinkError(e, this.lastPosition,