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集群的线程池大小,或者降低你的任务的并行度设置。
希望这些方法能帮助你解决问题。如果还有其他问题,欢迎继续提问。
从你提供的配置信息来看,你正在使用Flink CDC将MySQL数据库中的数据同步到Doris数据库。你的配置似乎是在尝试修改同步的数据库名称,但是你的配置中存在一些语法错误和不清晰的部分。
首先,你的配置中的一些部分似乎是缺失的,例如第8、9、18、19行的username和password字段。你需要确保所有的必要字段都被正确地填写。
其次,你的配置中的一些字符串值似乎是不完整的,例如第18行的username字段和第19行的password字段。你需要确保所有的字符串值都被正确地引号括起来。
最后,你的配置中的表名匹配模式似乎是不正确的。在你的配置中,source-table和sink-table的值都是"supply-chain..*",这意味着你正在尝试同步所有以"supply-chain."开头的表。然而,这似乎并不是你想要的结果。你需要根据你的实际需求来修改这些匹配模式。
总的来说,你需要修正你的配置文件中的错误和不清晰的部分,以确保Flink CDC能够正确地同步数据。如果你需要帮助来修复你的配置文件,你可以提供更多的上下文信息,或者寻求专业的技术支持。