Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 0D562200B4F for ; Tue, 12 Jul 2016 01:47:57 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 0BF19160A8B; Mon, 11 Jul 2016 23:47:57 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 52F86160A85 for ; Tue, 12 Jul 2016 01:47:56 +0200 (CEST) Received: (qmail 25248 invoked by uid 500); 11 Jul 2016 23:47:54 -0000 Mailing-List: contact commits-help@hbase.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@hbase.apache.org Delivered-To: mailing list commits@hbase.apache.org Received: (qmail 25011 invoked by uid 99); 11 Jul 2016 23:47:54 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Jul 2016 23:47:54 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 8ADA9DFFF8; Mon, 11 Jul 2016 23:47:54 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: eclark@apache.org To: commits@hbase.apache.org Date: Mon, 11 Jul 2016 23:47:54 -0000 Message-Id: <72e4c5e7efc34fbfa3e7b8cff6ac6200@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [01/50] [abbrv] hbase git commit: HBASE-16171 Fix the potential problems in TestHCM.testConnectionCloseAllowsInterrupt (Colin Ma) [Forced Update!] archived-at: Mon, 11 Jul 2016 23:47:57 -0000 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 Authored: Fri Jul 8 10:17:55 2016 -0700 Committer: stack 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);