Fixes.

apache · Jul 24, 2024 · b1445ff · b1445ff
1 parent b6016a2
commit b1445ff
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 3 deletions.
diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/RunWorkOrder.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/RunWorkOrder.java
@@ -488,7 +488,6 @@ private void writeDurableStorageSuccessFile()
       throw new ISE(
           e,
           "Unable to create success file at location[%s]",
-          DurableStorageUtils.SUCCESS_MARKER_FILENAME,
           durableStorageOutputChannelFactory.getSuccessFilePath()
       );
     }

diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/Worker.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/Worker.java
@@ -107,7 +107,7 @@ public interface Worker
    *
    * @throws IOException when the worker output is found but there is an error while reading it.
    */
-  ListenableFuture<InputStream> readChannel(StageId stageId, int partitionNumber, long offset) throws IOException;
+  ListenableFuture<InputStream> readChannel(StageId stageId, int partitionNumber, long offset);
 
   /**
    * Returns a snapshot of counters.

diff --git a/...ons-core/multi-stage-query/src/main/java/org/apache/druid/msq/rpc/ControllerResource.java b/...ons-core/multi-stage-query/src/main/java/org/apache/druid/msq/rpc/ControllerResource.java
@@ -93,7 +93,6 @@ public Response httpPostPartialKeyStatistics(
   @Produces(MediaType.APPLICATION_JSON)
   @Consumes(MediaType.APPLICATION_JSON)
   public Response httpPostDoneReadingInput(
-      @PathParam("queryId") final String queryId,
       @PathParam("stageNumber") final int stageNumber,
       @PathParam("workerNumber") final int workerNumber,
       @Context final HttpServletRequest req