diff --git hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestFSErrorsExposed.java hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestFSErrorsExposed.java index c508e70..361618d 100644 --- hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestFSErrorsExposed.java +++ hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestFSErrorsExposed.java @@ -181,9 +181,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"); @@ -196,8 +195,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. HTable table = new HTable(new Configuration(util.getConfiguration()), tableName); @@ -265,6 +263,7 @@ public class TestFSErrorsExposed { faultsStarted = true; } + @Override public int read(long position, byte[] buffer, int offset, int length) throws IOException { injectFault();