| commit | faf75b67f63a9e3995e46a1d0d0e2b0545670cf1 | [log] [tgz] |
|---|---|---|
| author | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Fri Apr 05 22:35:14 2013 +0000 |
| committer | madhusudancs@gmail.com <madhusudancs@gmail.com@123451ca-8445-de46-9d55-352943316053> | Fri Apr 05 22:35:14 2013 +0000 |
| tree | b0156dc6b0a4b20cf7fb01f106bb4f58bf24d001 | |
| parent | 01eca96facbf0ed11972b46147472c8f5c3a8ce3 [diff] | |
| parent | e6bd557436b27ea65cc94db5d102384c351bbde0 [diff] |
Re-creating a new branch for result distribution fixes. git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_rsd_fixes@3330 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 +}
diff --git a/hyracks/hyracks-storage-am-lsm-common/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/common/impls/AbstractLSMIndex.java b/hyracks/hyracks-storage-am-lsm-common/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/common/impls/AbstractLSMIndex.java index 0c6b9ab..610e1c7 100644 --- a/hyracks/hyracks-storage-am-lsm-common/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/common/impls/AbstractLSMIndex.java +++ b/hyracks/hyracks-storage-am-lsm-common/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/common/impls/AbstractLSMIndex.java
@@ -40,7 +40,7 @@ import edu.uci.ics.hyracks.storage.common.file.IFileMapProvider; public abstract class AbstractLSMIndex implements ILSMIndexInternal { - protected final static double MAX_BLOOM_FILTER_ACCEPTABLE_FALSE_POSITIVE_RATE = 0.1; + protected final static double MAX_BLOOM_FILTER_ACCEPTABLE_FALSE_POSITIVE_RATE = 0.01; protected final ILSMHarness lsmHarness;