Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-12728 buffered writes substantially less useful after removal of HTablePool (addendum for failing test in branch-1.0)

This commit is contained in:
Enis Soztutar 2015-01-24 17:57:04 -08:00
parent 4b9eaf5851
commit e180f0bdd1
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestFSErrorsExposed.java
View File

@ -180,9 +180,8 @@ public class TestFSErrorsExposed {
Assume.assumeTrue(!util.isReadShortCircuitOn()); Assume.assumeTrue(!util.isReadShortCircuitOn());
try { try {
// We set it not to run or it will trigger server shutdown while sync'ing // Make it fail faster.
// because all the datanodes are bad util.getConfiguration().setInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, 1);
util.getConfiguration().setInt(HConstants.HBASE_CLIENT_RETRIES_NUMBER, 3);
util.startMiniCluster(1); util.startMiniCluster(1);
TableName tableName = TableName.valueOf("table"); TableName tableName = TableName.valueOf("table");
@ -195,8 +194,7 @@ public class TestFSErrorsExposed {
.setBlockCacheEnabled(false) .setBlockCacheEnabled(false)
); );
admin.createTable(desc); 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 // 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. // above configuration on it; else we use the old one w/ 10 as default.
try (Table table = util.getConnection().getTable(tableName)) { try (Table table = util.getConnection().getTable(tableName)) {
@ -263,6 +261,7 @@ public class TestFSErrorsExposed {
faultsStarted = true; faultsStarted = true;
} }
@Override
public int read(long position, byte[] buffer, int offset, int length) public int read(long position, byte[] buffer, int offset, int length)
throws IOException { throws IOException {
injectFault(); injectFault();