启动canal时，线程池工作异常

2018-07-24 15:44:43.247 [destination = example , address = /22.5.229.239:3306 , EventParser] WARN c.a.otter.canal.parse.inbound.mysql.MysqlEventParser - prepare to find start position mysql-bin.000001:558240:null 2018-07-24 15:44:43.271 [destination = example , address = /22.5.229.239:3306 , EventParser] WARN c.a.otter.canal.parse.inbound.mysql.MysqlEventParser - find start position : EntryPosition[included=false,journalName=mysql-bin.000001,position=558240,serverId=,gtid=,timestamp=] 2018-07-24 15:44:43.331 [destination = example , address = /22.5.229.239:3306 , EventParser] WARN c.a.o.canal.parse.inbound.mysql.dbsync.DirectLogFetcher - Received EOF packet from server, apparent master disconnected. It's may be duplicate slaveId , check instance config 2018-07-24 15:45:00.446 [destination = example , address = /22.5.229.239:3306 , EventParser] WARN c.a.otter.canal.parse.inbound.mysql.MysqlEventParser - prepare to find start position just last position {"identity":{"slaveId":-1,"sourceAddress":{"address":"cbjup04","port":3306}},"postion":{"gtid":"","included":false,"journalName":"mysql-bin.000001","position":559146,"serverId":16782861,"timestamp":1532417891000}} 2018-07-24 15:45:00.447 [destination = example , address = /22.5.229.239:3306 , EventParser] WARN c.a.otter.canal.parse.inbound.mysql.MysqlEventParser - find start position : EntryPosition[included=false,journalName=mysql-bin.000001,position=559146,serverId=16782861,gtid=,timestamp=1532417891000] 2018-07-24 15:45:00.453 [destination = example , address = /22.5.229.239:3306 , EventParser] WARN c.a.o.canal.parse.inbound.mysql.dbsync.DirectLogFetcher - Received EOF packet from server, apparent master disconnected. It's may be duplicate slaveId , check instance config 2018-07-24 15:45:18.422 [destination = example , address = /22.5.229.239:3306 , EventParser] WARN c.a.otter.canal.parse.inbound.mysql.MysqlEventParser - prepare to find start position just last position {"identity":{"slaveId":-1,"sourceAddress":{"address":"cbjup04","port":3306}},"postion":{"gtid":"","included":false,"journalName":"mysql-bin.000001","position":559146,"serverId":16782861,"timestamp":1532417891000}} 2018-07-24 15:45:18.422 [destination = example , address = /22.5.229.239:3306 , EventParser] WARN c.a.otter.canal.parse.inbound.mysql.MysqlEventParser - find start position : EntryPosition[included=false,journalName=mysql-bin.000001,position=559146,serverId=16782861,gtid=,timestamp=1532417891000] 2018-07-24 15:45:18.426 [destination = example , address = /22.5.229.239:3306 , EventParser] WARN c.a.o.canal.parse.inbound.mysql.dbsync.DirectLogFetcher - Received EOF packet from server, apparent master disconnected. It's may be duplicate slaveId , check instance config 2018-07-24 15:45:18.440 [destination = example , address = /22.5.229.239:3306 , EventParser] ERROR c.a.otter.canal.parse.inbound.mysql.MysqlEventParser - parse events has an error java.util.concurrent.RejectedExecutionException: Task com.lmax.disruptor.WorkProcessor@58d43d50 rejected from java.util.concurrent.ThreadPoolExecutor@56057cbf[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0] at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2048) ~[na:1.7.0_45] at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:821) ~[na:1.7.0_45] at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1372) ~[na:1.7.0_45] at com.lmax.disruptor.WorkerPool.start(WorkerPool.java:140) ~[disruptor-3.4.2.jar:na] at com.alibaba.otter.canal.parse.inbound.mysql.MysqlMultiStageCoprocessor.start(MysqlMultiStageCoprocessor.java:122) ~[canal.parse-1.0.26-SNAPSHOT.jar:na] at com.alibaba.otter.canal.parse.inbound.mysql.MysqlMultiStageCoprocessor.reset(MysqlMultiStageCoprocessor.java:187) ~[canal.parse-1.0.26-SNAPSHOT.jar:na] at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$3.run(AbstractEventParser.java:306) ~[canal.parse-1.0.26-SNAPSHOT.jar:na] at java.lang.Thread.run(Thread.java:744) ~[na:1.7.0_45]

原提问者GitHub用户sky-mariner