You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by en...@apache.org on 2016/07/06 18:30:50 UTC

[2/2] hbase git commit: HBASE-16182 Increase IntegrationTestRpcClient timeout

HBASE-16182 Increase IntegrationTestRpcClient timeout


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/74090faa
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/74090faa
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/74090faa

Branch: refs/heads/branch-1
Commit: 74090faafe81ba42c02e1329c37b296b4b0aa6b7
Parents: 2d6cdfb
Author: Enis Soztutar <en...@apache.org>
Authored: Tue Jul 5 18:42:37 2016 -0700
Committer: Enis Soztutar <en...@apache.org>
Committed: Wed Jul 6 11:28:50 2016 -0700

----------------------------------------------------------------------
 .../org/apache/hadoop/hbase/ipc/IntegrationTestRpcClient.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/74090faa/hbase-it/src/test/java/org/apache/hadoop/hbase/ipc/IntegrationTestRpcClient.java
----------------------------------------------------------------------
diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/ipc/IntegrationTestRpcClient.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/ipc/IntegrationTestRpcClient.java
index 6c0fbcc..0a7ac8a 100644
--- a/hbase-it/src/test/java/org/apache/hadoop/hbase/ipc/IntegrationTestRpcClient.java
+++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/ipc/IntegrationTestRpcClient.java
@@ -163,7 +163,7 @@ public class IntegrationTestRpcClient {
 
         TestRpcServer rpcServer = new TestRpcServer(conf);
         rpcServer.start();
-        InetSocketAddress address = rpcServer.getListenerAddress();        
+        InetSocketAddress address = rpcServer.getListenerAddress();
         if (address == null) {
           throw new IOException("Listener channel is closed");
         }
@@ -296,6 +296,7 @@ public class IntegrationTestRpcClient {
       this.cluster = cluster;
       this.rpcClient = rpcClient;
       this.id = id;
+      this.setName(id);
     }
 
     @Override
@@ -371,7 +372,7 @@ public class IntegrationTestRpcClient {
   }
 
 
-  @Test (timeout = 900000)
+  @Test (timeout = 1800000)
   public void testRpcWithChaosMonkeyWithSyncClient() throws Throwable {
     for (int i = 0; i < numIterations; i++) {
       TimeoutThread.runWithTimeout(new Callable<Void>() {
@@ -388,7 +389,7 @@ public class IntegrationTestRpcClient {
           }
           return null;
         }
-      }, 90000);
+      }, 180000);
     }
   }