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 81bbbd08..749cfa61 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 @@ -454,7 +454,7 @@ public class MysqlMultiStageCoprocessor extends AbstractCanalLifeCycle implement } } - class MessageEventFactory implements EventFactory { + static class MessageEventFactory implements EventFactory { public MessageEvent newInstance() { return new MessageEvent();