You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2013/12/12 20:30:09 UTC
[2/5] git commit: ACCUMULO-1900 use the old deprecated API for 1.0
compatibility
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 <er...@gmail.com>
Authored: Thu Dec 12 14:26:46 2013 -0500
Committer: Eric Newton <er...@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);