environment
- canal version
v1.1.5-alpha-1
- mysql version
5.7
Issue Description
CanalRocketMQProducer 通过ExecutorTemplate并发执行时,由于提交到线程池里的分表任务、buildMessageData任务、分区发送任务有先后依赖,会出现worker线程相互依赖导致woker线程及主线程都分表任务占用,又一直等待buildMessageData任务、分区发送任务执行,出现一直等待现象
Steps to reproduce
Expected behaviour
线程池里的worker任务不应该产生依赖
Actual behaviour
If there is an exception, please attach the exception trace:
Just put your stack trace here!