Repository: hbase Updated Branches: refs/heads/branch-1.0 baf879967 -> 1f0eb701d
HBASE-12728 buffered writes substantially less useful after removal of HTablePool (addendum for failing test in branch-1.0) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/1f0eb701 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/1f0eb701 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/1f0eb701 Branch: refs/heads/branch-1.0 Commit: 1f0eb701dfc2794654c130f600a1614572155f17 Parents: baf8799 Author: Enis Soztutar <[email protected]> Authored: Sat Jan 24 17:57:04 2015 -0800 Committer: Enis Soztutar <[email protected]> Committed: Sat Jan 24 18:01:11 2015 -0800 ---------------------------------------------------------------------- .../hadoop/hbase/regionserver/TestFSErrorsExposed.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/1f0eb701/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestFSErrorsExposed.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestFSErrorsExposed.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestFSErrorsExposed.java index d24ba4f..4e97738 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestFSErrorsExposed.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestFSErrorsExposed.java @@ -180,9 +180,8 @@ public class TestFSErrorsExposed { Assume.assumeTrue(!util.isReadShortCircuitOn()); try { - // We set it not to run or it will trigger server shutdown while sync'ing - // because all the datanodes are bad - util.getConfiguration().setInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, 3); + // Make it fail faster. + util.getConfiguration().setInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, 1); util.startMiniCluster(1); TableName tableName = TableName.valueOf("table"); @@ -195,8 +194,7 @@ public class TestFSErrorsExposed { .setBlockCacheEnabled(false) ); admin.createTable(desc); - // Make it fail faster. - util.getConfiguration().setInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, 1); + // Make a new Configuration so it makes a new connection that has the // above configuration on it; else we use the old one w/ 10 as default. try (Table table = util.getConnection().getTable(tableName)) { @@ -263,6 +261,7 @@ public class TestFSErrorsExposed { faultsStarted = true; } + @Override public int read(long position, byte[] buffer, int offset, int length) throws IOException { injectFault();
