This is an automated email from the ASF dual-hosted git repository. sidmishra pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/atlas.git
The following commit(s) were added to refs/heads/master by this push: new 8b4ca74 ATLAS-4508: Made the deferred classification tasks sequential 8b4ca74 is described below commit 8b4ca740acf2b8e67dc89966fe4734b4c5d56b51 Author: Sidharth Mishra <sidharthkmis...@gmail.com> AuthorDate: Wed Dec 15 15:20:23 2021 -0800 ATLAS-4508: Made the deferred classification tasks sequential Signed-off-by: Sidharth Mishra <sidmis...@apache.org> --- .../src/main/java/org/apache/atlas/tasks/TaskManagement.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/repository/src/main/java/org/apache/atlas/tasks/TaskManagement.java b/repository/src/main/java/org/apache/atlas/tasks/TaskManagement.java index 9a519ba..97b9980 100644 --- a/repository/src/main/java/org/apache/atlas/tasks/TaskManagement.java +++ b/repository/src/main/java/org/apache/atlas/tasks/TaskManagement.java @@ -44,7 +44,7 @@ import java.util.concurrent.atomic.AtomicInteger; public class TaskManagement implements Service, ActiveStateChangeHandler { private static final Logger LOG = LoggerFactory.getLogger(TaskManagement.class); - private final ThreadLocal<TaskExecutor> taskExecutorThreadLocal = new ThreadLocal<>(); + private TaskExecutor taskExecutor; private final Configuration configuration; private final TaskRegistry registry; private final Statistics statistics; @@ -170,16 +170,16 @@ public class TaskManagement implements Service, ActiveStateChangeHandler { } } - private void dispatchTasks(List<AtlasTask> tasks) { + private synchronized void dispatchTasks(List<AtlasTask> tasks) { if (CollectionUtils.isEmpty(tasks)) { return; } - if (this.taskExecutorThreadLocal.get() == null) { - this.taskExecutorThreadLocal.set(new TaskExecutor(registry, taskTypeFactoryMap, statistics)); + if (this.taskExecutor == null) { + this.taskExecutor = new TaskExecutor(registry, taskTypeFactoryMap, statistics); } - this.taskExecutorThreadLocal.get().addAll(tasks); + this.taskExecutor.addAll(tasks); this.statistics.print(); }