Flink CDC有见这个报错不?
Caused by:java.util.concurrent.RejectedExecutionException:Task java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@6bd43365 rejected from java.util.concurrent.
ScheduledThreadPoolExecutor@9a6b4c7[Terminated, pool size =0, active threads =,queued tasks=, completed tasks =]
这个错误信息来自于Java的ScheduledThreadPoolExecutor类,具体的原因是RejectedExecutionException,也就是任务被拒绝执行。
这个错误通常发生在以下两种情况之一:
- 当线程池已经关闭,但仍然有任务提交时,这些任务会被拒绝。
- 当线程池的队列已满,且没有空闲的工作线程时,新的任务也会被拒绝。
对于你的问题,我建议你检查以下几点:
确认你的Flink CDC任务是否在正确的环境中运行。例如,如果你的任务在一个已经被关闭的Flink集群上运行,那么这个错误就可能发生。
检查你的Flink集群的配置。例如,你可以检查你的Flink集群的线程池大小,以及任务的并行度设置。如果线程池的大小太小,或者任务的并行度设置得太高,都可能导致这个错误。
如果可能的话,尝试增加你的Flink集群的线程池大小,或者降低你的任务的并行度设置。
希望这些方法能帮助你解决问题。如果还有其他问题,欢迎继续提问。