TAJO-1139: ExternalSortExec should delete the intermediate files. (jinho via hyunsik)
Closes #212 Project: http://git-wip-us.apache.org/repos/asf/tajo/repo Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/154da1e4 Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/154da1e4 Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/154da1e4 Branch: refs/heads/hbase_storage Commit: 154da1e492e9e1ad4e752dbf396f9d4f1973ec21 Parents: 0319b1f Author: Hyunsik Choi <[email protected]> Authored: Thu Oct 30 22:15:14 2014 -0700 Committer: Hyunsik Choi <[email protected]> Committed: Thu Oct 30 22:16:00 2014 -0700 ---------------------------------------------------------------------- CHANGES | 3 +++ .../org/apache/tajo/engine/planner/physical/PhysicalExec.java | 3 ++- 2 files changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tajo/blob/154da1e4/CHANGES ---------------------------------------------------------------------- diff --git a/CHANGES b/CHANGES index 46a335b..49c267b 100644 --- a/CHANGES +++ b/CHANGES @@ -32,6 +32,9 @@ Release 0.9.1 - unreleased BUG FIXES + TAJO-1139: ExternalSortExec should delete the intermediate files. + (jinho via hyunsik) + TAJO-1126: Join condition including functions throws IllegalArgumentException. (hyunsik) http://git-wip-us.apache.org/repos/asf/tajo/blob/154da1e4/tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/PhysicalExec.java ---------------------------------------------------------------------- diff --git a/tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/PhysicalExec.java b/tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/PhysicalExec.java index 31cfc4d..67fb29b 100644 --- a/tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/PhysicalExec.java +++ b/tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/PhysicalExec.java @@ -79,7 +79,8 @@ public abstract class PhysicalExec implements SchemaObject { } protected Path getExecutorTmpDir() { - return new Path(UUID.randomUUID().toString()); + return new Path(context.getQueryId().getQueryUnitId().getExecutionBlockId().getQueryId().toString(), + UUID.randomUUID().toString()); } public TableStats getInputStats() {
