ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject ignite git commit: Possible fix.
Date Tue, 31 May 2016 06:11:51 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-3202 6195303b5 -> 1bb30a092


Possible fix.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1bb30a09
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1bb30a09
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1bb30a09

Branch: refs/heads/ignite-3202
Commit: 1bb30a092c6b3db01c83ec30f5419dd735456e99
Parents: 6195303
Author: vozerov-gridgain <vozerov@gridgain.com>
Authored: Tue May 31 09:11:25 2016 +0300
Committer: vozerov-gridgain <vozerov@gridgain.com>
Committed: Tue May 31 09:11:25 2016 +0300

----------------------------------------------------------------------
 .../apache/ignite/hadoop/fs/CachingHadoopFileSystemFactory.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/1bb30a09/modules/hadoop/src/main/java/org/apache/ignite/hadoop/fs/CachingHadoopFileSystemFactory.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/hadoop/fs/CachingHadoopFileSystemFactory.java
b/modules/hadoop/src/main/java/org/apache/ignite/hadoop/fs/CachingHadoopFileSystemFactory.java
index 01c51a2..95d96f6 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/hadoop/fs/CachingHadoopFileSystemFactory.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/hadoop/fs/CachingHadoopFileSystemFactory.java
@@ -47,7 +47,7 @@ public class CachingHadoopFileSystemFactory extends BasicHadoopFileSystemFactory
     private final transient HadoopLazyConcurrentMap<String, FileSystem> cache = new
HadoopLazyConcurrentMap<>(
         new HadoopLazyConcurrentMap.ValueFactory<String, FileSystem>() {
             @Override public FileSystem createValue(String key) throws IOException {
-                return getWithMappedName(key);
+                return CachingHadoopFileSystemFactory.super.getWithMappedName(key);
             }
         }
     );
@@ -61,8 +61,7 @@ public class CachingHadoopFileSystemFactory extends BasicHadoopFileSystemFactory
 
     /** {@inheritDoc} */
     @Override public FileSystem getWithMappedName(String name) throws IOException {
-//        return cache.getOrCreate(name);
-        return cache.getOrCreate(IgfsUtils.fixUserName(name));
+        return cache.getOrCreate(name);
     }
 
     /** {@inheritDoc} */


Mime
View raw message