| commit | dce09db4251a1b9abc286992733c9132a89e920d | [log] [tgz] |
|---|---|---|
| author | pouria.pirzadeh@gmail.com <pouria.pirzadeh@gmail.com@123451ca-8445-de46-9d55-352943316053> | Thu Apr 04 22:48:55 2013 +0000 |
| committer | pouria.pirzadeh@gmail.com <pouria.pirzadeh@gmail.com@123451ca-8445-de46-9d55-352943316053> | Thu Apr 04 22:48:55 2013 +0000 |
| tree | f4102f5e9d751111f8b5f1eeb0c4c16be5045c3c | |
| parent | 53df0e5681a419f2eff2b4752ff1728b4e693296 [diff] |
merge back the fix for join probe files clean up after job is finished (reviewed by Yingyi) git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_lsm_staging@3316 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/OptimizedHybridHashJoin.java b/hyracks/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/OptimizedHybridHashJoin.java index 6e2b16a..c81bf54 100644 --- a/hyracks/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/OptimizedHybridHashJoin.java +++ b/hyracks/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/OptimizedHybridHashJoin.java
@@ -529,7 +529,7 @@ private void probeWrite(int pid, ByteBuffer buff) throws HyracksDataException { RunFileWriter pWriter = probeRFWriters[pid]; if (pWriter == null) { - FileReference file = ctx.createManagedWorkspaceFile(rel1Name); + FileReference file = ctx.getJobletContext().createManagedWorkspaceFile(rel1Name); pWriter = new RunFileWriter(file, ctx.getIOManager()); pWriter.open(); probeRFWriters[pid] = pWriter; @@ -621,4 +621,4 @@ public boolean isTableEmpty(){ return this.isTableEmpty; } -} \ No newline at end of file +}