hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ecl...@apache.org
Subject [01/50] [abbrv] hbase git commit: HBASE-16171 Fix the potential problems in TestHCM.testConnectionCloseAllowsInterrupt (Colin Ma) [Forced Update!]
Date Mon, 11 Jul 2016 23:47:54 GMT
Repository: hbase
Updated Branches:
  refs/heads/HBASE-14850 114817253 -> 0eb150f9d (forced update)


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/HBASE-14850
Commit: 5e0d97e0e95434b03ba886279180a031ed997dfd
Parents: a33097e
Author: stack <stack@apache.org>
Authored: Fri Jul 8 10:17:55 2016 -0700
Committer: stack <stack@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);


Mime
View raw message