diff --git a/indexing-service/src/main/java/io/druid/indexing/common/actions/TaskActionHolder.java b/indexing-service/src/main/java/io/druid/indexing/common/actions/TaskActionHolder.java index 04b533f43ff..1c839cfbd1c 100644 --- a/indexing-service/src/main/java/io/druid/indexing/common/actions/TaskActionHolder.java +++ b/indexing-service/src/main/java/io/druid/indexing/common/actions/TaskActionHolder.java @@ -25,10 +25,10 @@ import io.druid.indexing.common.task.Task; /** */ -public class TaskActionHolder +public class TaskActionHolder { private final Task task; - private final TaskAction action; + private final TaskAction action; @JsonCreator public TaskActionHolder( @@ -47,7 +47,7 @@ public class TaskActionHolder } @JsonProperty - public TaskAction getAction() + public TaskAction getAction() { return action; } diff --git a/indexing-service/src/main/java/io/druid/indexing/overlord/http/OverlordResource.java b/indexing-service/src/main/java/io/druid/indexing/overlord/http/OverlordResource.java index af4797b19f4..706036e5e6f 100644 --- a/indexing-service/src/main/java/io/druid/indexing/overlord/http/OverlordResource.java +++ b/indexing-service/src/main/java/io/druid/indexing/overlord/http/OverlordResource.java @@ -39,7 +39,6 @@ import io.druid.indexing.common.TaskStatus; import io.druid.indexing.common.actions.TaskActionClient; import io.druid.indexing.common.actions.TaskActionHolder; import io.druid.indexing.common.task.Task; -import io.druid.indexing.overlord.RemoteTaskRunner; import io.druid.indexing.overlord.TaskMaster; import io.druid.indexing.overlord.TaskQueue; import io.druid.indexing.overlord.TaskRunner; @@ -259,7 +258,7 @@ public class OverlordResource @POST @Path("/action") @Produces(MediaType.APPLICATION_JSON) - public Response doAction(final TaskActionHolder holder) + public Response doAction(final TaskActionHolder holder) { return asLeaderWith( taskMaster.getTaskActionClient(holder.getTask()), @@ -275,7 +274,7 @@ public class OverlordResource // or token that gets passed around. try { - final T ret = taskActionClient.submit(holder.getAction()); + final Object ret = taskActionClient.submit(holder.getAction()); retMap = Maps.newHashMap(); retMap.put("result", ret); }