You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2016/07/08 17:18:41 UTC
hbase git commit: HBASE-16171 Fix the potential problems in
TestHCM.testConnectionCloseAllowsInterrupt (Colin Ma)
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 <st...@apache.org>
Authored: Fri Jul 8 10:17:55 2016 -0700
Committer: stack <st...@apache.org>
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);