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);
