incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject git commit: Removing the forced creation of a new file system.
Date Tue, 28 Oct 2014 02:10:19 GMT
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 <amccurry@gmail.com>
Authored: Mon Oct 27 22:10:11 2014 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
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();


Mime
View raw message