diff --git a/merger/src/main/java/com/metamx/druid/merger/coordinator/TaskMasterLifecycle.java b/merger/src/main/java/com/metamx/druid/merger/coordinator/TaskMasterLifecycle.java index 69f77b3526c..da73ede5923 100644 --- a/merger/src/main/java/com/metamx/druid/merger/coordinator/TaskMasterLifecycle.java +++ b/merger/src/main/java/com/metamx/druid/merger/coordinator/TaskMasterLifecycle.java @@ -219,8 +219,13 @@ public class TaskMasterLifecycle return taskQueue; } - public TaskToolbox getTaskToolbox() + public TaskToolbox getTaskToolbox(Task task) { - return taskToolbox; + return taskToolboxFactory.build(task); + } + + public ResourceManagementScheduler getResourceManagementScheduler() + { + return resourceManagementScheduler; } }