Repository: incubator-blur Updated Branches: refs/heads/master a284f5ded -> 959fa9cb9
Enabling the streaming reads for better merge performance. Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/959fa9cb Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/959fa9cb Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/959fa9cb Branch: refs/heads/master Commit: 959fa9cb981cb5cb3e22bfaf4e8e933954316412 Parents: a284f5d Author: Aaron McCurry <[email protected]> Authored: Wed Nov 12 23:26:03 2014 -0500 Committer: Aaron McCurry <[email protected]> Committed: Wed Nov 12 23:26:03 2014 -0500 ---------------------------------------------------------------------- .../src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java | 2 +- .../main/java/org/apache/blur/store/hdfs/IndexInputMergeUtil.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/959fa9cb/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java ---------------------------------------------------------------------- diff --git a/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java b/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java index 60fc46e..6684376 100644 --- a/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java +++ b/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java @@ -228,7 +228,7 @@ public class HdfsDirectory extends Directory implements LastModified, HdfsSymlin Path path = getPath(name); Tracer trace = Trace.trace("filesystem - create", Trace.param("path", path)); try { - return _fileSystem.create(path, true, 1024 * 1024); + return _fileSystem.create(path); } finally { trace.done(); } http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/959fa9cb/blur-store/src/main/java/org/apache/blur/store/hdfs/IndexInputMergeUtil.java ---------------------------------------------------------------------- diff --git a/blur-store/src/main/java/org/apache/blur/store/hdfs/IndexInputMergeUtil.java b/blur-store/src/main/java/org/apache/blur/store/hdfs/IndexInputMergeUtil.java index c1cc9c5..dce111b 100644 --- a/blur-store/src/main/java/org/apache/blur/store/hdfs/IndexInputMergeUtil.java +++ b/blur-store/src/main/java/org/apache/blur/store/hdfs/IndexInputMergeUtil.java @@ -20,7 +20,7 @@ import org.apache.blur.utils.BlurConstants; public class IndexInputMergeUtil { - private static boolean streamSwitch = false; + private static boolean streamSwitch = true; public static boolean isMergeThread() { if (!streamSwitch) {
