Temporarily disabling block cache, there's seems to be a bug that causes the index to become corrupt.
Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/7834b04a Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/7834b04a Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/7834b04a Branch: refs/heads/0.2-dev Commit: 7834b04a66ecc4c454dca14ee13969f626abfb92 Parents: 4e63693 Author: Aaron McCurry <[email protected]> Authored: Mon Feb 18 20:48:15 2013 -0500 Committer: Aaron McCurry <[email protected]> Committed: Mon Feb 18 20:48:15 2013 -0500 ---------------------------------------------------------------------- .../indexserver/DistributedIndexServer.java | 9 ++++++--- 1 files changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/7834b04a/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/DistributedIndexServer.java ---------------------------------------------------------------------- diff --git a/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/DistributedIndexServer.java b/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/DistributedIndexServer.java index 320c2c4..c5098f7 100644 --- a/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/DistributedIndexServer.java +++ b/src/blur-core/src/main/java/org/apache/blur/manager/indexserver/DistributedIndexServer.java @@ -454,9 +454,12 @@ public class DistributedIndexServer extends AbstractIndexServer { Path hdfsDirPath = shardContext.getHdfsDirPath(); BlurLockFactory lockFactory = new BlurLockFactory(_configuration, hdfsDirPath, _nodeName, BlurConstants.getPid()); - Directory directory = shardContext.getDirectory(); - directory.setLockFactory(lockFactory); - Directory dir = new BlockDirectory(table + "_" + shard, directory, _cache); +// Directory directory = shardContext.getDirectory(); +// directory.setLockFactory(lockFactory); +// Directory dir = new BlockDirectory(table + "_" + shard, directory, _cache); + + Directory dir = shardContext.getDirectory(); + dir.setLockFactory(lockFactory); BlurIndex index; if (tableDescriptor.isReadOnly()) {
