From 638cda8022e8cf7636d07187a67b2f780a53021c Mon Sep 17 00:00:00 2001
From: Amatya <amatya.avadhanula@imply.io>
Date: Thu, 15 Sep 2022 17:50:15 +0530
Subject: [PATCH 1/4] Make httpRemote the default task runner

---
 docs/configuration/index.md                                     | 2 +-
 .../cluster/master/coordinator-overlord/runtime.properties      | 2 +-
 .../single-server/large/coordinator-overlord/runtime.properties | 2 +-
 .../medium/coordinator-overlord/runtime.properties              | 2 +-
 .../micro-quickstart/coordinator-overlord/runtime.properties    | 2 +-
 .../nano-quickstart/coordinator-overlord/runtime.properties     | 2 +-
 .../single-server/small/coordinator-overlord/runtime.properties | 2 +-
 .../xlarge/coordinator-overlord/runtime.properties              | 2 +-
 services/src/main/java/org/apache/druid/cli/CliOverlord.java    | 2 +-
 9 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/docs/configuration/index.md b/docs/configuration/index.md
index 49ed052fbcbc..e9f3fda2b9e2 100644
--- a/docs/configuration/index.md
+++ b/docs/configuration/index.md
@@ -1097,7 +1097,7 @@ These Overlord static configurations can be defined in the `overlord/runtime.pro
 
 |Property|Description|Default|
 |--------|-----------|-------|
-|`druid.indexer.runner.type`|Choices "local" or "remote". Indicates whether tasks should be run locally or in a distributed environment. Experimental task runner "httpRemote" is also available which is same as "remote" but uses HTTP to interact with Middle Managers instead of ZooKeeper.|local|
+|`druid.indexer.runner.type`|Indicates whether tasks should be run locally using "local" or in a distributed environment using "remote". The recommended option is "httpRemote", which is similar to "remote" but uses HTTP to interact with Middle Managers instead of ZooKeeper.|httpRemote|
 |`druid.indexer.storage.type`|Choices are "local" or "metadata". Indicates whether incoming tasks should be stored locally (in heap) or in metadata storage. "local" is mainly for internal testing while "metadata" is recommended in production because storing incoming tasks in metadata storage allows for tasks to be resumed if the Overlord should fail.|local|
 |`druid.indexer.storage.recentlyFinishedThreshold`|Duration of time to store task results. Default is 24 hours. If you have hundreds of tasks running in a day, consider increasing this threshold.|PT24H|
 |`druid.indexer.tasklock.forceTimeChunkLock`|_**Setting this to false is still experimental**_<br/> If set, all tasks are enforced to use time chunk lock. If not set, each task automatically chooses a lock type to use. This configuration can be overwritten by setting `forceTimeChunkLock` in the [task context](../ingestion/tasks.md#context). See [Task Locking & Priority](../ingestion/tasks.md#context) for more details about locking in tasks.|true|
diff --git a/examples/conf/druid/cluster/master/coordinator-overlord/runtime.properties b/examples/conf/druid/cluster/master/coordinator-overlord/runtime.properties
index 00071a83d7dc..693c3a7b91d4 100644
--- a/examples/conf/druid/cluster/master/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/cluster/master/coordinator-overlord/runtime.properties
@@ -30,5 +30,5 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=remote
+druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/examples/conf/druid/single-server/large/coordinator-overlord/runtime.properties b/examples/conf/druid/single-server/large/coordinator-overlord/runtime.properties
index 00071a83d7dc..693c3a7b91d4 100644
--- a/examples/conf/druid/single-server/large/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/single-server/large/coordinator-overlord/runtime.properties
@@ -30,5 +30,5 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=remote
+druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/examples/conf/druid/single-server/medium/coordinator-overlord/runtime.properties b/examples/conf/druid/single-server/medium/coordinator-overlord/runtime.properties
index 00071a83d7dc..693c3a7b91d4 100644
--- a/examples/conf/druid/single-server/medium/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/single-server/medium/coordinator-overlord/runtime.properties
@@ -30,5 +30,5 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=remote
+druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/examples/conf/druid/single-server/micro-quickstart/coordinator-overlord/runtime.properties b/examples/conf/druid/single-server/micro-quickstart/coordinator-overlord/runtime.properties
index 00071a83d7dc..693c3a7b91d4 100644
--- a/examples/conf/druid/single-server/micro-quickstart/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/single-server/micro-quickstart/coordinator-overlord/runtime.properties
@@ -30,5 +30,5 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=remote
+druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/examples/conf/druid/single-server/nano-quickstart/coordinator-overlord/runtime.properties b/examples/conf/druid/single-server/nano-quickstart/coordinator-overlord/runtime.properties
index 00071a83d7dc..693c3a7b91d4 100644
--- a/examples/conf/druid/single-server/nano-quickstart/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/single-server/nano-quickstart/coordinator-overlord/runtime.properties
@@ -30,5 +30,5 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=remote
+druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/examples/conf/druid/single-server/small/coordinator-overlord/runtime.properties b/examples/conf/druid/single-server/small/coordinator-overlord/runtime.properties
index 00071a83d7dc..693c3a7b91d4 100644
--- a/examples/conf/druid/single-server/small/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/single-server/small/coordinator-overlord/runtime.properties
@@ -30,5 +30,5 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=remote
+druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/examples/conf/druid/single-server/xlarge/coordinator-overlord/runtime.properties b/examples/conf/druid/single-server/xlarge/coordinator-overlord/runtime.properties
index 00071a83d7dc..693c3a7b91d4 100644
--- a/examples/conf/druid/single-server/xlarge/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/single-server/xlarge/coordinator-overlord/runtime.properties
@@ -30,5 +30,5 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=remote
+druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/services/src/main/java/org/apache/druid/cli/CliOverlord.java b/services/src/main/java/org/apache/druid/cli/CliOverlord.java
index 3a45975bf9d7..cb9b68788b4f 100644
--- a/services/src/main/java/org/apache/druid/cli/CliOverlord.java
+++ b/services/src/main/java/org/apache/druid/cli/CliOverlord.java
@@ -300,7 +300,7 @@ private void configureRunners(Binder binder)
                 binder,
                 "druid.indexer.runner.type",
                 Key.get(TaskRunnerFactory.class),
-                Key.get(ForkingTaskRunnerFactory.class)
+                Key.get(HttpRemoteTaskRunnerFactory.class)
             );
             final MapBinder<String, TaskRunnerFactory> biddy = PolyBind.optionBinder(
                 binder,

From 4c28fd18eff27c36b27789be017b4ecc29fb0cbb Mon Sep 17 00:00:00 2001
From: Amatya <amatya.avadhanula@imply.io>
Date: Thu, 15 Sep 2022 18:08:28 +0530
Subject: [PATCH 2/4] Make http based inventory and segment management default

---
 dev/intellij-setup.md                                       | 4 ++--
 docs/configuration/index.md                                 | 6 +++---
 .../druid/client/FilteredServerInventoryViewProvider.java   | 2 +-
 .../apache/druid/client/ServerInventoryViewProvider.java    | 2 +-
 .../druid/server/coordinator/DruidCoordinatorConfig.java    | 2 +-
 5 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/dev/intellij-setup.md b/dev/intellij-setup.md
index c2536e7b1316..5d6cc281db95 100644
--- a/dev/intellij-setup.md
+++ b/dev/intellij-setup.md
@@ -93,7 +93,7 @@ You can configure application definitions in XML for import into IntelliJ. Below
   <configuration default="false" name="Historical" type="Application" factoryName="Application">
     <extension name="coverage" enabled="false" merge="false" sample_coverage="true" runner="idea" />
     <option name="MAIN_CLASS_NAME" value="org.apache.druid.cli.Main" />
-    <option name="VM_PARAMETERS" value="-server -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Xmx2G -XX:MaxJavaStackTraceDepth=9999 -XX:+UseG1GC -XX:+PrintGCDetails -XX:+PrintGCTimeStamps -XX:+PrintAdaptiveSizePolicy -XX:+PrintReferenceGC -verbose:gc -XX:+PrintFlagsFinal -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager -Dorg.jboss.logging.provider=slf4j -Dlog4j.configurationFile=$PROJECT_DIR$/core/src/main/resources/log4j2.debug.xml -Ddruid.host=localhost -Ddruid.service=historical -Ddruid.processing.buffer.sizeBytes=100000000 -Ddruid.extensions.hadoopDependenciesDir=$PROJECT_DIR$/distribution/target/hadoop-dependencies/ -Ddruid.extensions.directory=$PROJECT_DIR$/distribution/target/extensions/ -Ddruid.extensions.loadList=[\&quot;druid-s3-extensions\&quot;,\&quot;druid-histogram\&quot;,\&quot;mysql-metadata-storage\&quot;] -Ddruid.historical.cache.useCache=false -Ddruid.historical.cache.populateCache=false -Ddruid.segmentCache.locations=&quot;[{\&quot;path\&quot;:\&quot;/tmp/druid/indexCache\&quot;,\&quot;maxSize\&quot;:10000000000}]&quot; -Ddruid.zk.service.host=localhost -Ddruid.processing.numThreads=1 -Ddruid.server.http.numThreads=50 -Ddruid.serverview.type=batch -Ddruid.emitter=logging" />
+    <option name="VM_PARAMETERS" value="-server -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Xmx2G -XX:MaxJavaStackTraceDepth=9999 -XX:+UseG1GC -XX:+PrintGCDetails -XX:+PrintGCTimeStamps -XX:+PrintAdaptiveSizePolicy -XX:+PrintReferenceGC -verbose:gc -XX:+PrintFlagsFinal -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager -Dorg.jboss.logging.provider=slf4j -Dlog4j.configurationFile=$PROJECT_DIR$/core/src/main/resources/log4j2.debug.xml -Ddruid.host=localhost -Ddruid.service=historical -Ddruid.processing.buffer.sizeBytes=100000000 -Ddruid.extensions.hadoopDependenciesDir=$PROJECT_DIR$/distribution/target/hadoop-dependencies/ -Ddruid.extensions.directory=$PROJECT_DIR$/distribution/target/extensions/ -Ddruid.extensions.loadList=[\&quot;druid-s3-extensions\&quot;,\&quot;druid-histogram\&quot;,\&quot;mysql-metadata-storage\&quot;] -Ddruid.historical.cache.useCache=false -Ddruid.historical.cache.populateCache=false -Ddruid.segmentCache.locations=&quot;[{\&quot;path\&quot;:\&quot;/tmp/druid/indexCache\&quot;,\&quot;maxSize\&quot;:10000000000}]&quot; -Ddruid.zk.service.host=localhost -Ddruid.processing.numThreads=1 -Ddruid.server.http.numThreads=50 -Ddruid.serverview.type=http -Ddruid.emitter=logging" />
     <option name="PROGRAM_PARAMETERS" value="server historical" />
     <option name="WORKING_DIRECTORY" value="file://$PROJECT_DIR$" />
     <option name="ALTERNATIVE_JRE_PATH_ENABLED" value="false" />
@@ -114,7 +114,7 @@ You can configure application definitions in XML for import into IntelliJ. Below
   <configuration default="false" name="Coordinator" type="Application" factoryName="Application">
     <extension name="coverage" enabled="false" merge="false" sample_coverage="true" runner="idea" />
     <option name="MAIN_CLASS_NAME" value="org.apache.druid.cli.Main" />
-    <option name="VM_PARAMETERS" value="-server -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Xmx256M -Xmx256M -XX:+UseG1GC -XX:+PrintGCDetails -XX:+PrintGCTimeStamps -XX:+PrintAdaptiveSizePolicy -XX:+PrintReferenceGC -verbose:gc -XX:+PrintFlagsFinal -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager -Dorg.jboss.logging.provider=slf4j -Ddruid.host=localhost -Ddruid.service=coordinator -Ddruid.extensions.directory=$PROJECT_DIR$/distribution/target/extensions/ -Ddruid.extensions.loadList=[\&quot;druid-s3-extensions\&quot;,\&quot;druid-histogram\&quot;,\&quot;mysql-metadata-storage\&quot;] -Ddruid.zk.service.host=localhost -Ddruid.metadata.storage.type=mysql -Ddruid.metadata.storage.connector.connectURI=&quot;jdbc:mysql://localhost:3306/druid&quot; -Ddruid.metadata.storage.connector.user=druid -Ddruid.metadata.storage.connector.password=diurd -Ddruid.serverview.type=batch -Ddruid.emitter=logging -Ddruid.coordinator.period=PT10S -Ddruid.coordinator.startDelay=PT5S" />
+    <option name="VM_PARAMETERS" value="-server -Duser.timezone=UTC -Dfile.encoding=UTF-8 -Xmx256M -Xmx256M -XX:+UseG1GC -XX:+PrintGCDetails -XX:+PrintGCTimeStamps -XX:+PrintAdaptiveSizePolicy -XX:+PrintReferenceGC -verbose:gc -XX:+PrintFlagsFinal -Djava.util.logging.manager=org.apache.logging.log4j.jul.LogManager -Dorg.jboss.logging.provider=slf4j -Ddruid.host=localhost -Ddruid.service=coordinator -Ddruid.extensions.directory=$PROJECT_DIR$/distribution/target/extensions/ -Ddruid.extensions.loadList=[\&quot;druid-s3-extensions\&quot;,\&quot;druid-histogram\&quot;,\&quot;mysql-metadata-storage\&quot;] -Ddruid.zk.service.host=localhost -Ddruid.metadata.storage.type=mysql -Ddruid.metadata.storage.connector.connectURI=&quot;jdbc:mysql://localhost:3306/druid&quot; -Ddruid.metadata.storage.connector.user=druid -Ddruid.metadata.storage.connector.password=diurd -Ddruid.serverview.type=http -Ddruid.emitter=logging -Ddruid.coordinator.period=PT10S -Ddruid.coordinator.startDelay=PT5S" />
     <option name="PROGRAM_PARAMETERS" value="server coordinator" />
     <option name="WORKING_DIRECTORY" value="file://$PROJECT_DIR$" />
     <option name="ALTERNATIVE_JRE_PATH_ENABLED" value="false" />
diff --git a/docs/configuration/index.md b/docs/configuration/index.md
index e9f3fda2b9e2..c2123e07d12d 100644
--- a/docs/configuration/index.md
+++ b/docs/configuration/index.md
@@ -872,8 +872,8 @@ These Coordinator static configurations can be defined in the `coordinator/runti
 ##### Segment Management
 |Property|Possible Values|Description|Default|
 |--------|---------------|-----------|-------|
-|`druid.serverview.type`|batch or http|Segment discovery method to use. "http" enables discovering segments using HTTP instead of ZooKeeper.|batch|
-|`druid.coordinator.loadqueuepeon.type`|curator or http|Whether to use "http" or "curator" implementation to assign segment loads/drops to historical|curator|
+|`druid.serverview.type`|batch or http|Segment discovery method to use. "http" enables discovering segments using HTTP instead of ZooKeeper.|http|
+|`druid.coordinator.loadqueuepeon.type`|curator or http|Whether to use "http" or "curator" implementation to assign segment loads/drops to historical|http|
 |`druid.coordinator.segment.awaitInitializationOnStart`|true or false|Whether the Coordinator will wait for its view of segments to fully initialize before starting up. If set to 'true', the Coordinator's HTTP server will not start up, and the Coordinator will not announce itself as available, until the server view is initialized.|true|
 
 ###### Additional config when "http" loadqueuepeon is used
@@ -1929,7 +1929,7 @@ See [cache configuration](#cache-configuration) for how to configure cache setti
 #### Segment Discovery
 |Property|Possible Values|Description|Default|
 |--------|---------------|-----------|-------|
-|`druid.serverview.type`|batch or http|Segment discovery method to use. "http" enables discovering segments using HTTP instead of ZooKeeper.|batch|
+|`druid.serverview.type`|batch or http|Segment discovery method to use. "http" enables discovering segments using HTTP instead of ZooKeeper.|http|
 |`druid.broker.segment.watchedTiers`|List of strings|The Broker watches segment announcements from processes that serve segments to build a cache to relate each process to the segments it serves. This configuration allows the Broker to only consider segments being served from a list of tiers. By default, Broker considers all tiers. This can be used to partition your dataSources in specific Historical tiers and configure brokers in partitions so that they are only queryable for specific dataSources. This config is mutually exclusive from `druid.broker.segment.ignoredTiers` and at most one of these can be configured on a Broker.|none|
 |`druid.broker.segment.ignoredTiers`|List of strings|The Broker watches segment announcements from processes that serve segments to build a cache to relate each process to the segments it serves. This configuration allows the Broker to ignore the segments being served from a list of tiers. By default, Broker considers all tiers. This config is mutually exclusive from `druid.broker.segment.watchedTiers` and at most one of these can be configured on a Broker.|none|
 |`druid.broker.segment.watchedDataSources`|List of strings|Broker watches the segment announcements from processes serving segments to build cache of which process is serving which segments, this configuration allows to only consider segments being served from a whitelist of dataSources. By default, Broker would consider all datasources. This can be used to configure brokers in partitions so that they are only queryable for specific dataSources.|none|
diff --git a/server/src/main/java/org/apache/druid/client/FilteredServerInventoryViewProvider.java b/server/src/main/java/org/apache/druid/client/FilteredServerInventoryViewProvider.java
index fdbb27e63823..26cd53ad1990 100644
--- a/server/src/main/java/org/apache/druid/client/FilteredServerInventoryViewProvider.java
+++ b/server/src/main/java/org/apache/druid/client/FilteredServerInventoryViewProvider.java
@@ -24,7 +24,7 @@
 import com.fasterxml.jackson.annotation.JsonTypeInfo;
 import com.google.inject.Provider;
 
-@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "type", defaultImpl = FilteredBatchServerInventoryViewProvider.class)
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "type", defaultImpl = FilteredHttpServerInventoryViewProvider.class)
 @JsonSubTypes(value = {
     @JsonSubTypes.Type(name = "batch", value = FilteredBatchServerInventoryViewProvider.class),
     @JsonSubTypes.Type(name = "http", value = FilteredHttpServerInventoryViewProvider.class)
diff --git a/server/src/main/java/org/apache/druid/client/ServerInventoryViewProvider.java b/server/src/main/java/org/apache/druid/client/ServerInventoryViewProvider.java
index bc87500f905f..3bbf85570530 100644
--- a/server/src/main/java/org/apache/druid/client/ServerInventoryViewProvider.java
+++ b/server/src/main/java/org/apache/druid/client/ServerInventoryViewProvider.java
@@ -25,7 +25,7 @@
 
 /**
  */
-@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "type", defaultImpl = BatchServerInventoryViewProvider.class)
+@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, property = "type", defaultImpl = HttpServerInventoryViewProvider.class)
 @JsonSubTypes(value = {
     @JsonSubTypes.Type(name = "batch", value = BatchServerInventoryViewProvider.class),
     @JsonSubTypes.Type(name = "http", value = HttpServerInventoryViewProvider.class),
diff --git a/server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinatorConfig.java b/server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinatorConfig.java
index c02baf9cc64b..cdd708ea9d30 100644
--- a/server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinatorConfig.java
+++ b/server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinatorConfig.java
@@ -110,7 +110,7 @@ public Duration getLoadQueuePeonRepeatDelay()
   @Config("druid.coordinator.loadqueuepeon.type")
   public String getLoadQueuePeonType()
   {
-    return "curator";
+    return "http";
   }
 
   @Config("druid.coordinator.curator.loadqueuepeon.numCallbackThreads")

From d595edb38d9d15f5b8ebd513778733934a2bae09 Mon Sep 17 00:00:00 2001
From: Amatya <amatya.avadhanula@imply.io>
Date: Fri, 16 Sep 2022 01:25:14 +0530
Subject: [PATCH 3/4] Remove task runner type from bundled configs

---
 .../druid/cluster/master/coordinator-overlord/runtime.properties | 1 -
 .../single-server/large/coordinator-overlord/runtime.properties  | 1 -
 .../single-server/medium/coordinator-overlord/runtime.properties | 1 -
 .../micro-quickstart/coordinator-overlord/runtime.properties     | 1 -
 .../nano-quickstart/coordinator-overlord/runtime.properties      | 1 -
 .../single-server/small/coordinator-overlord/runtime.properties  | 1 -
 .../single-server/xlarge/coordinator-overlord/runtime.properties | 1 -
 7 files changed, 7 deletions(-)

diff --git a/examples/conf/druid/cluster/master/coordinator-overlord/runtime.properties b/examples/conf/druid/cluster/master/coordinator-overlord/runtime.properties
index 693c3a7b91d4..c053823f8ed8 100644
--- a/examples/conf/druid/cluster/master/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/cluster/master/coordinator-overlord/runtime.properties
@@ -30,5 +30,4 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/examples/conf/druid/single-server/large/coordinator-overlord/runtime.properties b/examples/conf/druid/single-server/large/coordinator-overlord/runtime.properties
index 693c3a7b91d4..c053823f8ed8 100644
--- a/examples/conf/druid/single-server/large/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/single-server/large/coordinator-overlord/runtime.properties
@@ -30,5 +30,4 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/examples/conf/druid/single-server/medium/coordinator-overlord/runtime.properties b/examples/conf/druid/single-server/medium/coordinator-overlord/runtime.properties
index 693c3a7b91d4..c053823f8ed8 100644
--- a/examples/conf/druid/single-server/medium/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/single-server/medium/coordinator-overlord/runtime.properties
@@ -30,5 +30,4 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/examples/conf/druid/single-server/micro-quickstart/coordinator-overlord/runtime.properties b/examples/conf/druid/single-server/micro-quickstart/coordinator-overlord/runtime.properties
index 693c3a7b91d4..c053823f8ed8 100644
--- a/examples/conf/druid/single-server/micro-quickstart/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/single-server/micro-quickstart/coordinator-overlord/runtime.properties
@@ -30,5 +30,4 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/examples/conf/druid/single-server/nano-quickstart/coordinator-overlord/runtime.properties b/examples/conf/druid/single-server/nano-quickstart/coordinator-overlord/runtime.properties
index 693c3a7b91d4..c053823f8ed8 100644
--- a/examples/conf/druid/single-server/nano-quickstart/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/single-server/nano-quickstart/coordinator-overlord/runtime.properties
@@ -30,5 +30,4 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/examples/conf/druid/single-server/small/coordinator-overlord/runtime.properties b/examples/conf/druid/single-server/small/coordinator-overlord/runtime.properties
index 693c3a7b91d4..c053823f8ed8 100644
--- a/examples/conf/druid/single-server/small/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/single-server/small/coordinator-overlord/runtime.properties
@@ -30,5 +30,4 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata
diff --git a/examples/conf/druid/single-server/xlarge/coordinator-overlord/runtime.properties b/examples/conf/druid/single-server/xlarge/coordinator-overlord/runtime.properties
index 693c3a7b91d4..c053823f8ed8 100644
--- a/examples/conf/druid/single-server/xlarge/coordinator-overlord/runtime.properties
+++ b/examples/conf/druid/single-server/xlarge/coordinator-overlord/runtime.properties
@@ -30,5 +30,4 @@ druid.coordinator.asOverlord.overlordService=druid/overlord
 
 druid.indexer.queue.startDelay=PT5S
 
-druid.indexer.runner.type=httpRemote
 druid.indexer.storage.type=metadata

From d2335aa637ab9c9e68864c234b52fc35124b6cf4 Mon Sep 17 00:00:00 2001
From: Amatya <amatya.avadhanula@imply.io>
Date: Tue, 4 Oct 2022 14:28:12 +0530
Subject: [PATCH 4/4] Add test for coverage

---
 .../druid/server/coordinator/DruidCoordinatorConfigTest.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/server/src/test/java/org/apache/druid/server/coordinator/DruidCoordinatorConfigTest.java b/server/src/test/java/org/apache/druid/server/coordinator/DruidCoordinatorConfigTest.java
index 169ad39fa0d0..cfbe2b7de975 100644
--- a/server/src/test/java/org/apache/druid/server/coordinator/DruidCoordinatorConfigTest.java
+++ b/server/src/test/java/org/apache/druid/server/coordinator/DruidCoordinatorConfigTest.java
@@ -49,6 +49,7 @@ public void testDeserialization()
     Assert.assertEquals(Duration.millis(50), config.getLoadQueuePeonRepeatDelay());
     Assert.assertTrue(config.getCompactionSkipLockedIntervals());
     Assert.assertFalse(config.getCoordinatorKillIgnoreDurationToRetain());
+    Assert.assertEquals("http", config.getLoadQueuePeonType());
 
     //with non-defaults
     Properties props = new Properties();