Repository: incubator-blur Updated Branches: refs/heads/master dcdd25d79 -> 6557950ca
Removing the forced creation of a new file system. Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/6557950c Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/6557950c Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/6557950c Branch: refs/heads/master Commit: 6557950ca49b3d2ac84ab86e8b59d83bef351fa9 Parents: dcdd25d Author: Aaron McCurry <[email protected]> Authored: Mon Oct 27 22:10:11 2014 -0400 Committer: Aaron McCurry <[email protected]> Committed: Mon Oct 27 22:10:11 2014 -0400 ---------------------------------------------------------------------- .../java/org/apache/blur/store/hdfs_v2/HdfsKeyValueStore.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/6557950c/blur-store/src/main/java/org/apache/blur/store/hdfs_v2/HdfsKeyValueStore.java ---------------------------------------------------------------------- diff --git a/blur-store/src/main/java/org/apache/blur/store/hdfs_v2/HdfsKeyValueStore.java b/blur-store/src/main/java/org/apache/blur/store/hdfs_v2/HdfsKeyValueStore.java index a4108d8..9a2837e 100644 --- a/blur-store/src/main/java/org/apache/blur/store/hdfs_v2/HdfsKeyValueStore.java +++ b/blur-store/src/main/java/org/apache/blur/store/hdfs_v2/HdfsKeyValueStore.java @@ -155,7 +155,6 @@ public class HdfsKeyValueStore implements Store { } private final ConcurrentNavigableMap<BytesRef, Value> _pointers = new ConcurrentSkipListMap<BytesRef, Value>(COMP); - private final Configuration _configuration; private final Path _path; private final ReentrantReadWriteLock _readWriteLock; private final AtomicReference<SortedSet<FileStatus>> _fileStatus = new AtomicReference<SortedSet<FileStatus>>(); @@ -177,10 +176,8 @@ public class HdfsKeyValueStore implements Store { public HdfsKeyValueStore(Configuration configuration, Path path, long maxAmountAllowedPerFile) throws IOException { _maxAmountAllowedPerFile = maxAmountAllowedPerFile; - _configuration = configuration; _path = path; - _configuration.setBoolean("fs.hdfs.impl.disable.cache", true); - _fileSystem = FileSystem.get(_path.toUri(), _configuration); + _fileSystem = _path.getFileSystem(configuration); _fileSystem.mkdirs(_path); _readWriteLock = new ReentrantReadWriteLock(); _writeLock = _readWriteLock.writeLock();
