diff --git a/indexing-service/src/main/java/io/druid/indexing/common/task/HadoopIndexTask.java b/indexing-service/src/main/java/io/druid/indexing/common/task/HadoopIndexTask.java index c9e971bdeeb..ca38f90e3cc 100644 --- a/indexing-service/src/main/java/io/druid/indexing/common/task/HadoopIndexTask.java +++ b/indexing-service/src/main/java/io/druid/indexing/common/task/HadoopIndexTask.java @@ -86,6 +86,7 @@ public class HadoopIndexTask extends AbstractTask public HadoopIndexTask( @JsonProperty("id") String id, @JsonProperty("config") HadoopDruidIndexerSchema schema, + @JsonProperty("hadoopCoordinates") String hadoopCoordinates, @JsonProperty("hadoopDependencyCoordinates") List hadoopDependencyCoordinates ) { @@ -101,7 +102,7 @@ public class HadoopIndexTask extends AbstractTask this.schema = schema; this.hadoopDependencyCoordinates = hadoopDependencyCoordinates == null ? Arrays.asList( - defaultHadoopCoordinates + hadoopCoordinates == null ? defaultHadoopCoordinates : hadoopCoordinates ) : hadoopDependencyCoordinates; }