More cleanup

kfaraz · Jul 17, 2024 · 6d36f87 · 6d36f87
1 parent fa17419
commit 6d36f87
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 6 deletions.
diff --git a/...java/org/apache/druid/indexing/common/task/concurrent/ConcurrentReplaceAndAppendTest.java b/...java/org/apache/druid/indexing/common/task/concurrent/ConcurrentReplaceAndAppendTest.java
@@ -38,7 +38,6 @@
 import org.apache.druid.indexing.common.task.NoopTaskContextEnricher;
 import org.apache.druid.indexing.common.task.Task;
 import org.apache.druid.indexing.common.task.TestAppenderatorsManager;
-import org.apache.druid.indexing.overlord.RunnerFactory;
 import org.apache.druid.indexing.overlord.Segments;
 import org.apache.druid.indexing.overlord.TaskQueue;
 import org.apache.druid.indexing.overlord.TaskRunner;
@@ -142,7 +141,7 @@ public void setup()
         new TaskQueueConfig(null, new Period(0L), null, null, null, null),
         new DefaultTaskConfig(),
         getTaskStorage(),
-        RunnerFactory.of(taskRunner),
+        taskRunner,
         taskActionClientFactory,
         getLockbox(),
         new NoopServiceEmitter(),

diff --git a/...apache/druid/indexing/common/task/concurrent/ConcurrentReplaceAndStreamingAppendTest.java b/...apache/druid/indexing/common/task/concurrent/ConcurrentReplaceAndStreamingAppendTest.java
@@ -39,7 +39,6 @@
 import org.apache.druid.indexing.common.task.NoopTaskContextEnricher;
 import org.apache.druid.indexing.common.task.Task;
 import org.apache.druid.indexing.common.task.TestAppenderatorsManager;
-import org.apache.druid.indexing.overlord.RunnerFactory;
 import org.apache.druid.indexing.overlord.SegmentPublishResult;
 import org.apache.druid.indexing.overlord.Segments;
 import org.apache.druid.indexing.overlord.TaskQueue;
@@ -155,7 +154,7 @@ public void setUpIngestionTestBase() throws IOException
         new TaskQueueConfig(null, new Period(0L), null, null, null, null),
         new DefaultTaskConfig(),
         getTaskStorage(),
-        RunnerFactory.of(taskRunner),
+        taskRunner,
         taskActionClientFactory,
         getLockbox(),
         new NoopServiceEmitter(),

diff --git a/indexing-service/src/test/java/org/apache/druid/indexing/overlord/TaskLifecycleTest.java b/indexing-service/src/test/java/org/apache/druid/indexing/overlord/TaskLifecycleTest.java
@@ -693,7 +693,7 @@ private TaskQueue setUpTaskQueue(TaskStorage ts, TaskRunner tr) throws Exception
         tqc,
         new DefaultTaskConfig(),
         ts,
-        RunnerFactory.of(tr),
+        tr,
         tac,
         taskLockbox,
         emitter,

diff --git a/indexing-service/src/test/java/org/apache/druid/indexing/overlord/TaskLockConfigTest.java b/indexing-service/src/test/java/org/apache/druid/indexing/overlord/TaskLockConfigTest.java
@@ -119,7 +119,7 @@ public boolean isForceTimeChunkLock()
         queueConfig,
         new DefaultTaskConfig(),
         taskStorage,
-        RunnerFactory.of(taskRunner),
+        taskRunner,
         actionClientFactory,
         lockbox,
         emitter,