diff --git a/indexing-service/src/main/java/io/druid/indexing/worker/Worker.java b/indexing-service/src/main/java/io/druid/indexing/worker/Worker.java index 7173bd949d3..fc44905c65f 100644 --- a/indexing-service/src/main/java/io/druid/indexing/worker/Worker.java +++ b/indexing-service/src/main/java/io/druid/indexing/worker/Worker.java @@ -44,7 +44,7 @@ public class Worker @JsonProperty("version") String version ) { - this.scheme = scheme; + this.scheme = scheme == null ? "http" : scheme; // needed for backwards compatibility with older workers (pre-#4270) this.host = host; this.ip = ip; this.capacity = capacity;