这些作业请求非常密集,如果由单线程处理,它们将需要4-5个小时。在内部,这些作业请求有单独的较小任务,大约为300-400个。因此,我创建了一个任务执行器来并行处理它们。executor = new ThreadPoolTaskExecutor(); executor.setMaxPoolSize(200);
most recent failure: Lost task 0.3 in stage 0.0 (TID 3, ip-172-31-5-241.eu-central-1.compute.internal, executor4): ExecutorLostFailure (executor 4 exited caused by one of the running tasks) Reason: Container marked另一个问题是,这样的作业在抛出之前运行4-5个小时。这是一种预期行为吗?CSV文件有30-40个cols。
我不知道该