ACCUMULO-1900 use the old deprecated API for 1.0 compatibility

Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/998648d3
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/998648d3
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/998648d3

Branch: refs/heads/1.6.0-SNAPSHOT
Commit: 998648d3ddeebf9295e62ab6069bdd47e96e1420
Parents: 7eb838e
Author: Eric Newton <eric.new...@gmail.com>
Authored: Thu Dec 12 14:26:46 2013 -0500
Committer: Eric Newton <eric.new...@gmail.com>
Committed: Thu Dec 12 14:26:46 2013 -0500

----------------------------------------------------------------------
 .../org/apache/accumulo/server/tabletserver/log/DfsLogger.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/998648d3/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java
----------------------------------------------------------------------
diff --git 
a/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java
 
b/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java
index 2235242..213c885 100644
--- 
a/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java
+++ 
b/server/src/main/java/org/apache/accumulo/server/tabletserver/log/DfsLogger.java
@@ -258,7 +258,7 @@ public class DfsLogger {
       FileSystem fs = conf.getFileSystem();
       short replication = (short) 
conf.getConfiguration().getCount(Property.TSERV_WAL_REPLICATION);
       if (replication == 0)
-        replication = fs.getDefaultReplication(logPath);
+        replication = fs.getDefaultReplication();  // use 
fs.getDefaultReplication(logPath) in hadoop 1.2 or greater
       long blockSize = 
conf.getConfiguration().getMemoryInBytes(Property.TSERV_WAL_BLOCKSIZE);
       if (blockSize == 0)
         blockSize = (long) 
(conf.getConfiguration().getMemoryInBytes(Property.TSERV_WALOG_MAX_SIZE) * 1.1);

Reply via email to