Repository: hbase Updated Branches: refs/heads/master a33097e06 -> 5e0d97e0e
HBASE-16171 Fix the potential problems in TestHCM.testConnectionCloseAllowsInterrupt (Colin Ma) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/5e0d97e0 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/5e0d97e0 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/5e0d97e0 Branch: refs/heads/master Commit: 5e0d97e0e95434b03ba886279180a031ed997dfd Parents: a33097e Author: stack <[email protected]> Authored: Fri Jul 8 10:17:55 2016 -0700 Committer: stack <[email protected]> Committed: Fri Jul 8 10:18:36 2016 -0700 ---------------------------------------------------------------------- .../src/test/java/org/apache/hadoop/hbase/client/TestHCM.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/5e0d97e0/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestHCM.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestHCM.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestHCM.java index 4723fa8..1b20b76 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestHCM.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestHCM.java @@ -464,6 +464,10 @@ public class TestHCM { c2.setInt(HConstants.HBASE_CLIENT_PAUSE, 1); // don't wait between retries. c2.setInt(RpcClient.FAILED_SERVER_EXPIRY_KEY, 0); // Server do not really expire c2.setBoolean(RpcClient.SPECIFIC_WRITE_THREAD, allowsInterrupt); + // to avoid the client to be stuck when do the Get + c2.setInt(HConstants.HBASE_CLIENT_META_OPERATION_TIMEOUT, 10000); + c2.setInt(HConstants.HBASE_CLIENT_OPERATION_TIMEOUT, 10000); + c2.setInt(HConstants.HBASE_RPC_TIMEOUT_KEY, 5000); Connection connection = ConnectionFactory.createConnection(c2); final Table table = connection.getTable(tableName); @@ -488,6 +492,9 @@ public class TestHCM { done++; if (done % 100 == 0) LOG.info("done=" + done); + // without the sleep, will cause the exception for too many files in + // org.apache.hadoop.hdfs.server.datanode.DataXceiver + Thread.sleep(100); } } catch (Throwable t) { failed.set(t);
