运行时间超过几个小时报错

[ly147369]

当运行时间超过几个小时就会报这个错误

[ly147369]

求作者解答 万分感谢

[xizixuejie]

根据你的截图来看，很久没有收到消息，猜测可能是长时间未通讯断开连接，这个我也没遇到过。我一直用的kafka模式，要不你改下 canal 服务端的 canal.instance.network.soTimeout 配置试试看

[Hisioni]

问题原因可能由于是 ThreadPoolAutoConfiguration 里线程池配置：

new ThreadPoolExecutor(20, 100, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(1024), factory, new ThreadPoolExecutor.AbortPolicy());

一个事物里涉及到太多数据变化后，提交事物后将线程池占满了导致拒绝引起的