This is an automated email from the ASF dual-hosted git repository.
gian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new 89cf9b263dc RunWorkOrder: Skip creating sorterTmpDir up front. (#18077)
89cf9b263dc is described below
commit 89cf9b263dc16238bd1493414826ea087f50d168
Author: Gian Merlino <[email protected]>
AuthorDate: Wed Jun 4 11:27:56 2025 -0700
RunWorkOrder: Skip creating sorterTmpDir up front. (#18077)
There's no need to create it upfront, because it will be created on
demand if we actually need it. And, if we don't end up needing it
(because the sort can be done in memory), then we can skip creating
it altogether.
---
.../src/main/java/org/apache/druid/msq/exec/RunWorkOrder.java | 5 -----
1 file changed, 5 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
index b7c378d9414..e08a1bf081a 100644
---
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
@@ -823,11 +823,6 @@ public class RunWorkOrder
final StageDefinition stageDefinition =
workOrder.getStageDefinition();
final File sorterTmpDir = frameContext.tempDir("super-sort");
- FileUtils.mkdirp(sorterTmpDir);
- if (!sorterTmpDir.isDirectory()) {
- throw new IOException("Cannot create directory: " +
sorterTmpDir);
- }
-
final WorkerMemoryParameters memoryParameters =
frameContext.memoryParameters();
final SuperSorter sorter = new SuperSorter(
resultAndChannels.getOutputChannels().getAllReadableChannels(),
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
