You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by mb...@apache.org on 2019/12/30 04:50:58 UTC
[asterixdb] 03/06: [ASTERIXDB-2686][RT] Run files are not removed
on time
This is an automated email from the ASF dual-hosted git repository.
mblow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git
commit 672a36b64a0632b72aa4b4df59635ceaa0e340de
Author: Ali Alsuliman <al...@gmail.com>
AuthorDate: Mon Dec 9 11:16:33 2019 -0800
[ASTERIXDB-2686][RT] Run files are not removed on time
- user model changes: no
- storage format changes: no
- interface changes: no
Details:
Remove run files on time.
Change-Id: Iacff5cef38cee147712bc1ff947ffa40efb0d162
Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/4423
Tested-by: Jenkins <je...@fulliautomatix.ics.uci.edu>
Integration-Tests: Jenkins <je...@fulliautomatix.ics.uci.edu>
Reviewed-by: Dmitry Lychagin <dm...@couchbase.com>
---
.../hyracks/algebricks/runtime/operators/win/WindowPartitionWriter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/win/WindowPartitionWriter.java b/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/win/WindowPartitionWriter.java
index b3eb317..6a75f3c 100644
--- a/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/win/WindowPartitionWriter.java
+++ b/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/win/WindowPartitionWriter.java
@@ -104,7 +104,7 @@ final class WindowPartitionWriter {
copyToFrame(frameBuffer, writerFrame);
} else {
if (fileWriter == null) {
- FileReference file = ctx.getJobletContext().createManagedWorkspaceFile(fileNamePrefix);
+ FileReference file = ctx.createManagedWorkspaceFile(fileNamePrefix);
fileWriter = new RunFileWriter(file, ctx.getIoManager());
fileWriter.open();
}