我面临以下错误：
我写了一个基于Spark流（Dstream）的应用程序来提取来自PubSub的消息 . 不幸的是，我在执行这项工作时遇到了错误 . 实际上我使用由4个节点组成的集群来执行spark Job .
运行10分钟后没有任何特定错误，我永久得到以下错误：
错误org.apache.spark.streaming.CheckpointWriter：无法将检查点任务提交给线程池执行程序java.util.concurrent.RejectedExecutionException：从java.util拒绝任务org.apache.spark.streaming.CheckpointWriter$CheckpointWriteHandler@68395dc9 . concurrent.ThreadPoolExecutor@1a1acc25 [正在运行，池大小= 1，活动线程= 1，排队任务= 1000，已完成任务= 412]