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 B1DE9200CE1 for ; Thu, 31 Aug 2017 17:13:35 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id B044716B441; Thu, 31 Aug 2017 15:13:35 +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 5FE8C16B43A for ; Thu, 31 Aug 2017 17:13:33 +0200 (CEST) Received: (qmail 42428 invoked by uid 500); 31 Aug 2017 15:13:29 -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 41274 invoked by uid 99); 31 Aug 2017 15:13:28 -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; Thu, 31 Aug 2017 15:13:28 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 800AEF55DB; Thu, 31 Aug 2017 15:13:27 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: git-site-role@apache.org To: commits@hbase.apache.org Date: Thu, 31 Aug 2017 15:13:47 -0000 Message-Id: <9059d5dbf8114675a9b57a3eaae2b990@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [22/22] hbase-site git commit: Published site at . archived-at: Thu, 31 Aug 2017 15:13:35 -0000 Published site at . Project: http://git-wip-us.apache.org/repos/asf/hbase-site/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase-site/commit/6f0c8299 Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/6f0c8299 Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/6f0c8299 Branch: refs/heads/asf-site Commit: 6f0c8299254374b7908d4b46aa93aaa650ce2746 Parents: ef3f07f Author: jenkins Authored: Thu Aug 31 15:13:15 2017 +0000 Committer: jenkins Committed: Thu Aug 31 15:13:15 2017 +0000 ---------------------------------------------------------------------- acid-semantics.html | 4 +- apache_hbase_reference_guide.pdf | 6 +- .../hbase/zookeeper/MiniZooKeeperCluster.html | 8 +- .../hbase/zookeeper/MiniZooKeeperCluster.html | 487 ++--- book.html | 2 +- bulk-loads.html | 4 +- checkstyle-aggregate.html | 168 +- checkstyle.rss | 6 +- coc.html | 4 +- cygwin.html | 4 +- dependencies.html | 4 +- dependency-convergence.html | 4 +- dependency-info.html | 4 +- dependency-management.html | 4 +- devapidocs/constant-values.html | 29 +- devapidocs/index-all.html | 14 + .../hbase/backup/BackupRequest.Builder.html | 17 +- .../hadoop/hbase/backup/BackupRequest.html | 93 +- .../BackupRestoreConstants.BackupCommand.html | 44 +- .../hbase/backup/BackupRestoreConstants.html | 65 +- .../hadoop/hbase/backup/RestoreDriver.html | 30 +- .../backup/class-use/BackupRequest.Builder.html | 4 + .../impl/BackupCommands.BackupSetCommand.html | 32 +- .../impl/BackupCommands.CancelCommand.html | 8 +- .../backup/impl/BackupCommands.Command.html | 18 +- .../impl/BackupCommands.CreateCommand.html | 16 +- .../impl/BackupCommands.DeleteCommand.html | 10 +- .../impl/BackupCommands.DescribeCommand.html | 8 +- .../backup/impl/BackupCommands.HelpCommand.html | 8 +- .../impl/BackupCommands.HistoryCommand.html | 18 +- .../impl/BackupCommands.MergeCommand.html | 12 +- .../impl/BackupCommands.ProgressCommand.html | 8 +- .../impl/BackupCommands.RepairCommand.html | 12 +- .../hbase/backup/impl/BackupCommands.html | 36 +- .../hadoop/hbase/backup/package-tree.html | 2 +- .../hbase/classification/package-tree.html | 6 +- .../hadoop/hbase/client/package-tree.html | 24 +- .../hadoop/hbase/filter/package-tree.html | 10 +- .../hadoop/hbase/io/hfile/package-tree.html | 6 +- .../apache/hadoop/hbase/ipc/package-tree.html | 2 +- .../hadoop/hbase/mapreduce/package-tree.html | 4 +- .../hbase/master/balancer/package-tree.html | 2 +- .../hadoop/hbase/master/package-tree.html | 4 +- .../hbase/master/procedure/package-tree.html | 2 +- .../hadoop/hbase/monitoring/package-tree.html | 2 +- .../org/apache/hadoop/hbase/package-tree.html | 14 +- .../hadoop/hbase/procedure2/package-tree.html | 4 +- .../hadoop/hbase/quotas/package-tree.html | 6 +- .../hadoop/hbase/regionserver/package-tree.html | 18 +- .../regionserver/querymatcher/package-tree.html | 4 +- .../replication/regionserver/package-tree.html | 2 +- .../hadoop/hbase/rest/model/package-tree.html | 2 +- .../hbase/security/access/package-tree.html | 4 +- .../hadoop/hbase/security/package-tree.html | 2 +- .../apache/hadoop/hbase/util/package-tree.html | 8 +- .../apache/hadoop/hbase/wal/package-tree.html | 2 +- .../hbase/zookeeper/MiniZooKeeperCluster.html | 14 +- .../org/apache/hadoop/hbase/Version.html | 6 +- .../hbase/backup/BackupRequest.Builder.html | 154 +- .../hadoop/hbase/backup/BackupRequest.html | 154 +- .../BackupRestoreConstants.BackupCommand.html | 60 +- .../hbase/backup/BackupRestoreConstants.html | 60 +- .../hadoop/hbase/backup/RestoreDriver.html | 452 ++-- .../impl/BackupCommands.BackupSetCommand.html | 1926 +++++++++--------- .../impl/BackupCommands.CancelCommand.html | 1926 +++++++++--------- .../backup/impl/BackupCommands.Command.html | 1926 +++++++++--------- .../impl/BackupCommands.CreateCommand.html | 1926 +++++++++--------- .../impl/BackupCommands.DeleteCommand.html | 1926 +++++++++--------- .../impl/BackupCommands.DescribeCommand.html | 1926 +++++++++--------- .../backup/impl/BackupCommands.HelpCommand.html | 1926 +++++++++--------- .../impl/BackupCommands.HistoryCommand.html | 1926 +++++++++--------- .../impl/BackupCommands.MergeCommand.html | 1926 +++++++++--------- .../impl/BackupCommands.ProgressCommand.html | 1926 +++++++++--------- .../impl/BackupCommands.RepairCommand.html | 1926 +++++++++--------- .../hbase/backup/impl/BackupCommands.html | 1926 +++++++++--------- .../hbase/zookeeper/MiniZooKeeperCluster.html | 487 ++--- export_control.html | 4 +- hbase-build-configuration/dependencies.html | 4 +- .../dependency-convergence.html | 4 +- hbase-build-configuration/dependency-info.html | 4 +- .../dependency-management.html | 4 +- .../hbase-annotations/checkstyle.html | 4 +- .../hbase-annotations/dependencies.html | 4 +- .../dependency-convergence.html | 4 +- .../hbase-annotations/dependency-info.html | 4 +- .../dependency-management.html | 4 +- .../hbase-annotations/index.html | 4 +- .../hbase-annotations/integration.html | 4 +- .../hbase-annotations/issue-tracking.html | 4 +- .../hbase-annotations/license.html | 208 +- .../hbase-annotations/mail-lists.html | 4 +- .../hbase-annotations/plugin-management.html | 4 +- .../hbase-annotations/plugins.html | 4 +- .../hbase-annotations/project-info.html | 4 +- .../hbase-annotations/project-reports.html | 4 +- .../hbase-annotations/project-summary.html | 4 +- .../hbase-annotations/source-repository.html | 4 +- .../hbase-annotations/team-list.html | 4 +- .../hbase-archetypes/dependencies.html | 4 +- .../dependency-convergence.html | 4 +- .../hbase-archetypes/dependency-info.html | 4 +- .../hbase-archetypes/dependency-management.html | 4 +- .../hbase-archetype-builder/dependencies.html | 4 +- .../dependency-convergence.html | 4 +- .../dependency-info.html | 4 +- .../dependency-management.html | 4 +- .../hbase-archetype-builder/index.html | 4 +- .../hbase-archetype-builder/integration.html | 4 +- .../hbase-archetype-builder/issue-tracking.html | 4 +- .../hbase-archetype-builder/license.html | 208 +- .../hbase-archetype-builder/mail-lists.html | 4 +- .../plugin-management.html | 4 +- .../hbase-archetype-builder/plugins.html | 4 +- .../hbase-archetype-builder/project-info.html | 4 +- .../project-summary.html | 4 +- .../source-repository.html | 4 +- .../hbase-archetype-builder/team-list.html | 4 +- .../hbase-client-project/checkstyle.html | 4 +- .../hbase-client-project/dependencies.html | 4 +- .../dependency-convergence.html | 4 +- .../hbase-client-project/dependency-info.html | 4 +- .../dependency-management.html | 4 +- .../hbase-client-project/index.html | 4 +- .../hbase-client-project/integration.html | 4 +- .../hbase-client-project/issue-tracking.html | 4 +- .../hbase-client-project/license.html | 208 +- .../hbase-client-project/mail-lists.html | 4 +- .../hbase-client-project/plugin-management.html | 4 +- .../hbase-client-project/plugins.html | 4 +- .../hbase-client-project/project-info.html | 4 +- .../hbase-client-project/project-reports.html | 4 +- .../hbase-client-project/project-summary.html | 4 +- .../hbase-client-project/source-repository.html | 4 +- .../hbase-client-project/team-list.html | 4 +- .../hbase-shaded-client-project/checkstyle.html | 4 +- .../dependencies.html | 4 +- .../dependency-convergence.html | 4 +- .../dependency-info.html | 4 +- .../dependency-management.html | 4 +- .../hbase-shaded-client-project/index.html | 4 +- .../integration.html | 4 +- .../issue-tracking.html | 4 +- .../hbase-shaded-client-project/license.html | 4 +- .../hbase-shaded-client-project/mail-lists.html | 4 +- .../plugin-management.html | 4 +- .../hbase-shaded-client-project/plugins.html | 4 +- .../project-info.html | 4 +- .../project-reports.html | 4 +- .../project-summary.html | 4 +- .../source-repository.html | 4 +- .../hbase-shaded-client-project/team-list.html | 4 +- .../hbase-archetypes/index.html | 4 +- .../hbase-archetypes/integration.html | 4 +- .../hbase-archetypes/issue-tracking.html | 4 +- .../hbase-archetypes/license.html | 4 +- .../hbase-archetypes/mail-lists.html | 4 +- .../hbase-archetypes/plugin-management.html | 4 +- .../hbase-archetypes/plugins.html | 4 +- .../hbase-archetypes/project-info.html | 4 +- .../hbase-archetypes/project-summary.html | 4 +- .../hbase-archetypes/source-repository.html | 4 +- .../hbase-archetypes/team-list.html | 4 +- .../hbase-spark/checkstyle.html | 4 +- .../hbase-spark/dependencies.html | 4 +- .../hbase-spark/dependency-convergence.html | 4 +- .../hbase-spark/dependency-info.html | 4 +- .../hbase-spark/dependency-management.html | 4 +- .../hbase-spark/index.html | 4 +- .../hbase-spark/integration.html | 4 +- .../hbase-spark/issue-tracking.html | 4 +- .../hbase-spark/license.html | 208 +- .../hbase-spark/mail-lists.html | 4 +- .../hbase-spark/plugin-management.html | 4 +- .../hbase-spark/plugins.html | 4 +- .../hbase-spark/project-info.html | 4 +- .../hbase-spark/project-reports.html | 4 +- .../hbase-spark/project-summary.html | 4 +- .../hbase-spark/source-repository.html | 4 +- .../hbase-spark/team-list.html | 4 +- hbase-build-configuration/index.html | 4 +- hbase-build-configuration/integration.html | 4 +- hbase-build-configuration/issue-tracking.html | 4 +- hbase-build-configuration/license.html | 4 +- hbase-build-configuration/mail-lists.html | 4 +- .../plugin-management.html | 4 +- hbase-build-configuration/plugins.html | 4 +- hbase-build-configuration/project-info.html | 4 +- hbase-build-configuration/project-summary.html | 4 +- .../source-repository.html | 4 +- hbase-build-configuration/team-list.html | 4 +- hbase-shaded-check-invariants/checkstyle.html | 4 +- hbase-shaded-check-invariants/dependencies.html | 4 +- .../dependency-convergence.html | 4 +- .../dependency-info.html | 4 +- .../dependency-management.html | 4 +- hbase-shaded-check-invariants/index.html | 4 +- hbase-shaded-check-invariants/integration.html | 4 +- .../issue-tracking.html | 4 +- hbase-shaded-check-invariants/license.html | 4 +- hbase-shaded-check-invariants/mail-lists.html | 4 +- .../plugin-management.html | 4 +- hbase-shaded-check-invariants/plugins.html | 4 +- hbase-shaded-check-invariants/project-info.html | 4 +- .../project-reports.html | 4 +- .../project-summary.html | 4 +- .../source-repository.html | 4 +- hbase-shaded-check-invariants/team-list.html | 4 +- index.html | 4 +- integration.html | 4 +- issue-tracking.html | 4 +- license.html | 6 +- mail-lists.html | 4 +- metrics.html | 4 +- old_news.html | 4 +- plugin-management.html | 4 +- plugins.html | 4 +- poweredbyhbase.html | 4 +- project-info.html | 4 +- project-reports.html | 4 +- project-summary.html | 4 +- pseudo-distributed.html | 4 +- replication.html | 4 +- resources.html | 4 +- source-repository.html | 4 +- sponsors.html | 4 +- supportingprojects.html | 4 +- team-list.html | 4 +- 227 files changed, 14194 insertions(+), 13048 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6f0c8299/acid-semantics.html ---------------------------------------------------------------------- diff --git a/acid-semantics.html b/acid-semantics.html index 1169a34..1c4a166 100644 --- a/acid-semantics.html +++ b/acid-semantics.html @@ -7,7 +7,7 @@ - + Apache HBase – Apache HBase (TM) ACID Properties @@ -606,7 +606,7 @@ under the License. --> <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved. - <li id="publishDate" class="pull-right">Last Published: 2017-08-30</li> + <li id="publishDate" class="pull-right">Last Published: 2017-08-31</li> </p> </div> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6f0c8299/apache_hbase_reference_guide.pdf ---------------------------------------------------------------------- diff --git a/apache_hbase_reference_guide.pdf b/apache_hbase_reference_guide.pdf index 13dfc4d..db27700 100644 --- a/apache_hbase_reference_guide.pdf +++ b/apache_hbase_reference_guide.pdf @@ -5,8 +5,8 @@ /Author (Apache HBase Team) /Creator (Asciidoctor PDF 1.5.0.alpha.15, based on Prawn 2.2.2) /Producer (Apache HBase Team) -/ModDate (D:20170830144646+00'00') -/CreationDate (D:20170830144646+00'00') +/ModDate (D:20170831144637+00'00') +/CreationDate (D:20170831144637+00'00') >> endobj 2 0 obj @@ -27334,7 +27334,7 @@ endobj endobj 136 0 obj << /Limits [(__anchor-top) (adding.new.node)] -/Names [(__anchor-top) 25 0 R (__indexterm-6971294) 3261 0 R (__indexterm-6973544) 3263 0 R (__indexterm-6975606) 3264 0 R (__indexterm-6977480) 3265 0 R (acid) 891 0 R (add-metric-name-and-function-to-hadoop-compat-interface) 3360 0 R (add-the-implementation-to-both-hadoop-1-and-hadoop-2-compat-modules) 3361 0 R (add.metrics) 3358 0 R (adding-a-new-chapter-to-the-hbase-reference-guide) 3599 0 R (adding.new.node) 2858 0 R] +/Names [(__anchor-top) 25 0 R (__indexterm-6971298) 3261 0 R (__indexterm-6973548) 3263 0 R (__indexterm-6975610) 3264 0 R (__indexterm-6977484) 3265 0 R (acid) 891 0 R (add-metric-name-and-function-to-hadoop-compat-interface) 3360 0 R (add-the-implementation-to-both-hadoop-1-and-hadoop-2-compat-modules) 3361 0 R (add.metrics) 3358 0 R (adding-a-new-chapter-to-the-hbase-reference-guide) 3599 0 R (adding.new.node) 2858 0 R] >> endobj 137 0 obj http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6f0c8299/apidocs/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html ---------------------------------------------------------------------- diff --git a/apidocs/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html b/apidocs/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html index 3612fa8..5eff509 100644 --- a/apidocs/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html +++ b/apidocs/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html @@ -365,7 +365,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>shutdown</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html#line.292">shutdown</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html#line.295">shutdown</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -379,7 +379,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>killCurrentActiveZooKeeperServer</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html#line.326">killCurrentActiveZooKeeperServer</a>() +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html#line.329">killCurrentActiveZooKeeperServer</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true" title="class or interface in java.lang">InterruptedException</a></pre> <dl> @@ -398,7 +398,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>killOneBackupZooKeeperServer</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html#line.367">killOneBackupZooKeeperServer</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html#line.370">killOneBackupZooKeeperServer</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true" title="class or interface in java.lang">InterruptedException</a></pre> <div class="block">Kill one back up ZK servers</div> @@ -415,7 +415,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>getClientPort</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html#line.465">getClientPort</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html#line.468">getClientPort</a>()</pre> </li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6f0c8299/apidocs/src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html ---------------------------------------------------------------------- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html b/apidocs/src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html index 9d4a644..77768b8 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.html @@ -233,248 +233,251 @@ <span class="sourceLineNo">225</span> }<a name="line.225"></a> <span class="sourceLineNo">226</span><a name="line.226"></a> <span class="sourceLineNo">227</span> ZooKeeperServer server = new ZooKeeperServer(dir, dir, tickTimeToUse);<a name="line.227"></a> -<span class="sourceLineNo">228</span> NIOServerCnxnFactory standaloneServerFactory;<a name="line.228"></a> -<span class="sourceLineNo">229</span> while (true) {<a name="line.229"></a> -<span class="sourceLineNo">230</span> try {<a name="line.230"></a> -<span class="sourceLineNo">231</span> standaloneServerFactory = new NIOServerCnxnFactory();<a name="line.231"></a> -<span class="sourceLineNo">232</span> standaloneServerFactory.configure(<a name="line.232"></a> -<span class="sourceLineNo">233</span> new InetSocketAddress(currentClientPort),<a name="line.233"></a> -<span class="sourceLineNo">234</span> configuration.getInt(HConstants.ZOOKEEPER_MAX_CLIENT_CNXNS, 1000));<a name="line.234"></a> -<span class="sourceLineNo">235</span> } catch (BindException e) {<a name="line.235"></a> -<span class="sourceLineNo">236</span> LOG.debug("Failed binding ZK Server to client port: " +<a name="line.236"></a> -<span class="sourceLineNo">237</span> currentClientPort, e);<a name="line.237"></a> -<span class="sourceLineNo">238</span> // We're told to use some port but it's occupied, fail<a name="line.238"></a> -<span class="sourceLineNo">239</span> if (hasValidClientPortInList(i)) {<a name="line.239"></a> -<span class="sourceLineNo">240</span> return -1;<a name="line.240"></a> -<span class="sourceLineNo">241</span> }<a name="line.241"></a> -<span class="sourceLineNo">242</span> // This port is already in use, try to use another.<a name="line.242"></a> -<span class="sourceLineNo">243</span> tentativePort = selectClientPort(tentativePort);<a name="line.243"></a> -<span class="sourceLineNo">244</span> currentClientPort = tentativePort;<a name="line.244"></a> -<span class="sourceLineNo">245</span> continue;<a name="line.245"></a> -<span class="sourceLineNo">246</span> }<a name="line.246"></a> -<span class="sourceLineNo">247</span> break;<a name="line.247"></a> -<span class="sourceLineNo">248</span> }<a name="line.248"></a> -<span class="sourceLineNo">249</span><a name="line.249"></a> -<span class="sourceLineNo">250</span> // Start up this ZK server<a name="line.250"></a> -<span class="sourceLineNo">251</span> standaloneServerFactory.startup(server);<a name="line.251"></a> -<span class="sourceLineNo">252</span> // Runs a 'stat' against the servers.<a name="line.252"></a> -<span class="sourceLineNo">253</span> if (!waitForServerUp(currentClientPort, connectionTimeout)) {<a name="line.253"></a> -<span class="sourceLineNo">254</span> throw new IOException("Waiting for startup of standalone server");<a name="line.254"></a> -<span class="sourceLineNo">255</span> }<a name="line.255"></a> -<span class="sourceLineNo">256</span><a name="line.256"></a> -<span class="sourceLineNo">257</span> // We have selected a port as a client port. Update clientPortList if necessary.<a name="line.257"></a> -<span class="sourceLineNo">258</span> if (clientPortList.size() <= i) { // it is not in the list, add the port<a name="line.258"></a> -<span class="sourceLineNo">259</span> clientPortList.add(currentClientPort);<a name="line.259"></a> -<span class="sourceLineNo">260</span> }<a name="line.260"></a> -<span class="sourceLineNo">261</span> else if (clientPortList.get(i) <= 0) { // the list has invalid port, update with valid port<a name="line.261"></a> -<span class="sourceLineNo">262</span> clientPortList.remove(i);<a name="line.262"></a> -<span class="sourceLineNo">263</span> clientPortList.add(i, currentClientPort);<a name="line.263"></a> -<span class="sourceLineNo">264</span> }<a name="line.264"></a> -<span class="sourceLineNo">265</span><a name="line.265"></a> -<span class="sourceLineNo">266</span> standaloneServerFactoryList.add(standaloneServerFactory);<a name="line.266"></a> -<span class="sourceLineNo">267</span> zooKeeperServers.add(server);<a name="line.267"></a> -<span class="sourceLineNo">268</span> }<a name="line.268"></a> -<span class="sourceLineNo">269</span><a name="line.269"></a> -<span class="sourceLineNo">270</span> // set the first one to be active ZK; Others are backups<a name="line.270"></a> -<span class="sourceLineNo">271</span> activeZKServerIndex = 0;<a name="line.271"></a> -<span class="sourceLineNo">272</span> started = true;<a name="line.272"></a> -<span class="sourceLineNo">273</span> int clientPort = clientPortList.get(activeZKServerIndex);<a name="line.273"></a> -<span class="sourceLineNo">274</span> LOG.info("Started MiniZooKeeperCluster and ran successful 'stat' " +<a name="line.274"></a> -<span class="sourceLineNo">275</span> "on client port=" + clientPort);<a name="line.275"></a> -<span class="sourceLineNo">276</span> return clientPort;<a name="line.276"></a> -<span class="sourceLineNo">277</span> }<a name="line.277"></a> -<span class="sourceLineNo">278</span><a name="line.278"></a> -<span class="sourceLineNo">279</span> private void createDir(File dir) throws IOException {<a name="line.279"></a> -<span class="sourceLineNo">280</span> try {<a name="line.280"></a> -<span class="sourceLineNo">281</span> if (!dir.exists()) {<a name="line.281"></a> -<span class="sourceLineNo">282</span> dir.mkdirs();<a name="line.282"></a> -<span class="sourceLineNo">283</span> }<a name="line.283"></a> -<span class="sourceLineNo">284</span> } catch (SecurityException e) {<a name="line.284"></a> -<span class="sourceLineNo">285</span> throw new IOException("creating dir: " + dir, e);<a name="line.285"></a> -<span class="sourceLineNo">286</span> }<a name="line.286"></a> -<span class="sourceLineNo">287</span> }<a name="line.287"></a> -<span class="sourceLineNo">288</span><a name="line.288"></a> -<span class="sourceLineNo">289</span> /**<a name="line.289"></a> -<span class="sourceLineNo">290</span> * @throws IOException<a name="line.290"></a> -<span class="sourceLineNo">291</span> */<a name="line.291"></a> -<span class="sourceLineNo">292</span> public void shutdown() throws IOException {<a name="line.292"></a> -<span class="sourceLineNo">293</span> // shut down all the zk servers<a name="line.293"></a> -<span class="sourceLineNo">294</span> for (int i = 0; i < standaloneServerFactoryList.size(); i++) {<a name="line.294"></a> -<span class="sourceLineNo">295</span> NIOServerCnxnFactory standaloneServerFactory =<a name="line.295"></a> -<span class="sourceLineNo">296</span> standaloneServerFactoryList.get(i);<a name="line.296"></a> -<span class="sourceLineNo">297</span> int clientPort = clientPortList.get(i);<a name="line.297"></a> -<span class="sourceLineNo">298</span><a name="line.298"></a> -<span class="sourceLineNo">299</span> standaloneServerFactory.shutdown();<a name="line.299"></a> -<span class="sourceLineNo">300</span> if (!waitForServerDown(clientPort, connectionTimeout)) {<a name="line.300"></a> -<span class="sourceLineNo">301</span> throw new IOException("Waiting for shutdown of standalone server");<a name="line.301"></a> -<span class="sourceLineNo">302</span> }<a name="line.302"></a> -<span class="sourceLineNo">303</span> }<a name="line.303"></a> -<span class="sourceLineNo">304</span> standaloneServerFactoryList.clear();<a name="line.304"></a> -<span class="sourceLineNo">305</span><a name="line.305"></a> -<span class="sourceLineNo">306</span> for (ZooKeeperServer zkServer: zooKeeperServers) {<a name="line.306"></a> -<span class="sourceLineNo">307</span> //explicitly close ZKDatabase since ZookeeperServer does not close them<a name="line.307"></a> -<span class="sourceLineNo">308</span> zkServer.getZKDatabase().close();<a name="line.308"></a> -<span class="sourceLineNo">309</span> }<a name="line.309"></a> -<span class="sourceLineNo">310</span> zooKeeperServers.clear();<a name="line.310"></a> -<span class="sourceLineNo">311</span><a name="line.311"></a> -<span class="sourceLineNo">312</span> // clear everything<a name="line.312"></a> -<span class="sourceLineNo">313</span> if (started) {<a name="line.313"></a> -<span class="sourceLineNo">314</span> started = false;<a name="line.314"></a> -<span class="sourceLineNo">315</span> activeZKServerIndex = 0;<a name="line.315"></a> -<span class="sourceLineNo">316</span> clientPortList.clear();<a name="line.316"></a> -<span class="sourceLineNo">317</span> LOG.info("Shutdown MiniZK cluster with all ZK servers");<a name="line.317"></a> -<span class="sourceLineNo">318</span> }<a name="line.318"></a> -<span class="sourceLineNo">319</span> }<a name="line.319"></a> -<span class="sourceLineNo">320</span><a name="line.320"></a> -<span class="sourceLineNo">321</span> /**@return clientPort return clientPort if there is another ZK backup can run<a name="line.321"></a> -<span class="sourceLineNo">322</span> * when killing the current active; return -1, if there is no backups.<a name="line.322"></a> -<span class="sourceLineNo">323</span> * @throws IOException<a name="line.323"></a> -<span class="sourceLineNo">324</span> * @throws InterruptedException<a name="line.324"></a> -<span class="sourceLineNo">325</span> */<a name="line.325"></a> -<span class="sourceLineNo">326</span> public int killCurrentActiveZooKeeperServer() throws IOException,<a name="line.326"></a> -<span class="sourceLineNo">327</span> InterruptedException {<a name="line.327"></a> -<span class="sourceLineNo">328</span> if (!started || activeZKServerIndex < 0) {<a name="line.328"></a> -<span class="sourceLineNo">329</span> return -1;<a name="line.329"></a> -<span class="sourceLineNo">330</span> }<a name="line.330"></a> -<span class="sourceLineNo">331</span><a name="line.331"></a> -<span class="sourceLineNo">332</span> // Shutdown the current active one<a name="line.332"></a> -<span class="sourceLineNo">333</span> NIOServerCnxnFactory standaloneServerFactory =<a name="line.333"></a> -<span class="sourceLineNo">334</span> standaloneServerFactoryList.get(activeZKServerIndex);<a name="line.334"></a> -<span class="sourceLineNo">335</span> int clientPort = clientPortList.get(activeZKServerIndex);<a name="line.335"></a> -<span class="sourceLineNo">336</span><a name="line.336"></a> -<span class="sourceLineNo">337</span> standaloneServerFactory.shutdown();<a name="line.337"></a> -<span class="sourceLineNo">338</span> if (!waitForServerDown(clientPort, connectionTimeout)) {<a name="line.338"></a> -<span class="sourceLineNo">339</span> throw new IOException("Waiting for shutdown of standalone server");<a name="line.339"></a> -<span class="sourceLineNo">340</span> }<a name="line.340"></a> -<span class="sourceLineNo">341</span><a name="line.341"></a> -<span class="sourceLineNo">342</span> zooKeeperServers.get(activeZKServerIndex).getZKDatabase().close();<a name="line.342"></a> -<span class="sourceLineNo">343</span><a name="line.343"></a> -<span class="sourceLineNo">344</span> // remove the current active zk server<a name="line.344"></a> -<span class="sourceLineNo">345</span> standaloneServerFactoryList.remove(activeZKServerIndex);<a name="line.345"></a> -<span class="sourceLineNo">346</span> clientPortList.remove(activeZKServerIndex);<a name="line.346"></a> -<span class="sourceLineNo">347</span> zooKeeperServers.remove(activeZKServerIndex);<a name="line.347"></a> -<span class="sourceLineNo">348</span> LOG.info("Kill the current active ZK servers in the cluster " +<a name="line.348"></a> -<span class="sourceLineNo">349</span> "on client port: " + clientPort);<a name="line.349"></a> -<span class="sourceLineNo">350</span><a name="line.350"></a> -<span class="sourceLineNo">351</span> if (standaloneServerFactoryList.isEmpty()) {<a name="line.351"></a> -<span class="sourceLineNo">352</span> // there is no backup servers;<a name="line.352"></a> -<span class="sourceLineNo">353</span> return -1;<a name="line.353"></a> -<span class="sourceLineNo">354</span> }<a name="line.354"></a> -<span class="sourceLineNo">355</span> clientPort = clientPortList.get(activeZKServerIndex);<a name="line.355"></a> -<span class="sourceLineNo">356</span> LOG.info("Activate a backup zk server in the cluster " +<a name="line.356"></a> -<span class="sourceLineNo">357</span> "on client port: " + clientPort);<a name="line.357"></a> -<span class="sourceLineNo">358</span> // return the next back zk server's port<a name="line.358"></a> -<span class="sourceLineNo">359</span> return clientPort;<a name="line.359"></a> -<span class="sourceLineNo">360</span> }<a name="line.360"></a> -<span class="sourceLineNo">361</span><a name="line.361"></a> -<span class="sourceLineNo">362</span> /**<a name="line.362"></a> -<span class="sourceLineNo">363</span> * Kill one back up ZK servers<a name="line.363"></a> -<span class="sourceLineNo">364</span> * @throws IOException<a name="line.364"></a> -<span class="sourceLineNo">365</span> * @throws InterruptedException<a name="line.365"></a> -<span class="sourceLineNo">366</span> */<a name="line.366"></a> -<span class="sourceLineNo">367</span> public void killOneBackupZooKeeperServer() throws IOException,<a name="line.367"></a> -<span class="sourceLineNo">368</span> InterruptedException {<a name="line.368"></a> -<span class="sourceLineNo">369</span> if (!started || activeZKServerIndex < 0 ||<a name="line.369"></a> -<span class="sourceLineNo">370</span> standaloneServerFactoryList.size() <= 1) {<a name="line.370"></a> -<span class="sourceLineNo">371</span> return ;<a name="line.371"></a> -<span class="sourceLineNo">372</span> }<a name="line.372"></a> -<span class="sourceLineNo">373</span><a name="line.373"></a> -<span class="sourceLineNo">374</span> int backupZKServerIndex = activeZKServerIndex+1;<a name="line.374"></a> -<span class="sourceLineNo">375</span> // Shutdown the current active one<a name="line.375"></a> -<span class="sourceLineNo">376</span> NIOServerCnxnFactory standaloneServerFactory =<a name="line.376"></a> -<span class="sourceLineNo">377</span> standaloneServerFactoryList.get(backupZKServerIndex);<a name="line.377"></a> -<span class="sourceLineNo">378</span> int clientPort = clientPortList.get(backupZKServerIndex);<a name="line.378"></a> -<span class="sourceLineNo">379</span><a name="line.379"></a> -<span class="sourceLineNo">380</span> standaloneServerFactory.shutdown();<a name="line.380"></a> -<span class="sourceLineNo">381</span> if (!waitForServerDown(clientPort, connectionTimeout)) {<a name="line.381"></a> -<span class="sourceLineNo">382</span> throw new IOException("Waiting for shutdown of standalone server");<a name="line.382"></a> -<span class="sourceLineNo">383</span> }<a name="line.383"></a> -<span class="sourceLineNo">384</span><a name="line.384"></a> -<span class="sourceLineNo">385</span> zooKeeperServers.get(backupZKServerIndex).getZKDatabase().close();<a name="line.385"></a> -<span class="sourceLineNo">386</span><a name="line.386"></a> -<span class="sourceLineNo">387</span> // remove this backup zk server<a name="line.387"></a> -<span class="sourceLineNo">388</span> standaloneServerFactoryList.remove(backupZKServerIndex);<a name="line.388"></a> -<span class="sourceLineNo">389</span> clientPortList.remove(backupZKServerIndex);<a name="line.389"></a> -<span class="sourceLineNo">390</span> zooKeeperServers.remove(backupZKServerIndex);<a name="line.390"></a> -<span class="sourceLineNo">391</span> LOG.info("Kill one backup ZK servers in the cluster " +<a name="line.391"></a> -<span class="sourceLineNo">392</span> "on client port: " + clientPort);<a name="line.392"></a> -<span class="sourceLineNo">393</span> }<a name="line.393"></a> -<span class="sourceLineNo">394</span><a name="line.394"></a> -<span class="sourceLineNo">395</span> // XXX: From o.a.zk.t.ClientBase<a name="line.395"></a> -<span class="sourceLineNo">396</span> private static boolean waitForServerDown(int port, long timeout) throws IOException {<a name="line.396"></a> -<span class="sourceLineNo">397</span> long start = System.currentTimeMillis();<a name="line.397"></a> -<span class="sourceLineNo">398</span> while (true) {<a name="line.398"></a> -<span class="sourceLineNo">399</span> try {<a name="line.399"></a> -<span class="sourceLineNo">400</span> Socket sock = new Socket("localhost", port);<a name="line.400"></a> -<span class="sourceLineNo">401</span> try {<a name="line.401"></a> -<span class="sourceLineNo">402</span> OutputStream outstream = sock.getOutputStream();<a name="line.402"></a> -<span class="sourceLineNo">403</span> outstream.write("stat".getBytes());<a name="line.403"></a> -<span class="sourceLineNo">404</span> outstream.flush();<a name="line.404"></a> -<span class="sourceLineNo">405</span> } finally {<a name="line.405"></a> -<span class="sourceLineNo">406</span> sock.close();<a name="line.406"></a> -<span class="sourceLineNo">407</span> }<a name="line.407"></a> -<span class="sourceLineNo">408</span> } catch (IOException e) {<a name="line.408"></a> -<span class="sourceLineNo">409</span> return true;<a name="line.409"></a> -<span class="sourceLineNo">410</span> }<a name="line.410"></a> -<span class="sourceLineNo">411</span><a name="line.411"></a> -<span class="sourceLineNo">412</span> if (System.currentTimeMillis() > start + timeout) {<a name="line.412"></a> -<span class="sourceLineNo">413</span> break;<a name="line.413"></a> -<span class="sourceLineNo">414</span> }<a name="line.414"></a> -<span class="sourceLineNo">415</span> try {<a name="line.415"></a> -<span class="sourceLineNo">416</span> Thread.sleep(250);<a name="line.416"></a> -<span class="sourceLineNo">417</span> } catch (InterruptedException e) {<a name="line.417"></a> -<span class="sourceLineNo">418</span> throw (InterruptedIOException)new InterruptedIOException().initCause(e);<a name="line.418"></a> -<span class="sourceLineNo">419</span> }<a name="line.419"></a> -<span class="sourceLineNo">420</span> }<a name="line.420"></a> -<span class="sourceLineNo">421</span> return false;<a name="line.421"></a> -<span class="sourceLineNo">422</span> }<a name="line.422"></a> -<span class="sourceLineNo">423</span><a name="line.423"></a> -<span class="sourceLineNo">424</span> // XXX: From o.a.zk.t.ClientBase<a name="line.424"></a> -<span class="sourceLineNo">425</span> private static boolean waitForServerUp(int port, long timeout) throws IOException {<a name="line.425"></a> -<span class="sourceLineNo">426</span> long start = System.currentTimeMillis();<a name="line.426"></a> -<span class="sourceLineNo">427</span> while (true) {<a name="line.427"></a> -<span class="sourceLineNo">428</span> try {<a name="line.428"></a> -<span class="sourceLineNo">429</span> Socket sock = new Socket("localhost", port);<a name="line.429"></a> -<span class="sourceLineNo">430</span> BufferedReader reader = null;<a name="line.430"></a> -<span class="sourceLineNo">431</span> try {<a name="line.431"></a> -<span class="sourceLineNo">432</span> OutputStream outstream = sock.getOutputStream();<a name="line.432"></a> -<span class="sourceLineNo">433</span> outstream.write("stat".getBytes());<a name="line.433"></a> -<span class="sourceLineNo">434</span> outstream.flush();<a name="line.434"></a> -<span class="sourceLineNo">435</span><a name="line.435"></a> -<span class="sourceLineNo">436</span> Reader isr = new InputStreamReader(sock.getInputStream());<a name="line.436"></a> -<span class="sourceLineNo">437</span> reader = new BufferedReader(isr);<a name="line.437"></a> -<span class="sourceLineNo">438</span> String line = reader.readLine();<a name="line.438"></a> -<span class="sourceLineNo">439</span> if (line != null && line.startsWith("Zookeeper version:")) {<a name="line.439"></a> -<span class="sourceLineNo">440</span> return true;<a name="line.440"></a> -<span class="sourceLineNo">441</span> }<a name="line.441"></a> -<span class="sourceLineNo">442</span> } finally {<a name="line.442"></a> -<span class="sourceLineNo">443</span> sock.close();<a name="line.443"></a> -<span class="sourceLineNo">444</span> if (reader != null) {<a name="line.444"></a> -<span class="sourceLineNo">445</span> reader.close();<a name="line.445"></a> -<span class="sourceLineNo">446</span> }<a name="line.446"></a> -<span class="sourceLineNo">447</span> }<a name="line.447"></a> -<span class="sourceLineNo">448</span> } catch (IOException e) {<a name="line.448"></a> -<span class="sourceLineNo">449</span> // ignore as this is expected<a name="line.449"></a> -<span class="sourceLineNo">450</span> LOG.info("server localhost:" + port + " not up " + e);<a name="line.450"></a> -<span class="sourceLineNo">451</span> }<a name="line.451"></a> -<span class="sourceLineNo">452</span><a name="line.452"></a> -<span class="sourceLineNo">453</span> if (System.currentTimeMillis() > start + timeout) {<a name="line.453"></a> -<span class="sourceLineNo">454</span> break;<a name="line.454"></a> -<span class="sourceLineNo">455</span> }<a name="line.455"></a> -<span class="sourceLineNo">456</span> try {<a name="line.456"></a> -<span class="sourceLineNo">457</span> Thread.sleep(250);<a name="line.457"></a> -<span class="sourceLineNo">458</span> } catch (InterruptedException e) {<a name="line.458"></a> -<span class="sourceLineNo">459</span> throw (InterruptedIOException)new InterruptedIOException().initCause(e);<a name="line.459"></a> -<span class="sourceLineNo">460</span> }<a name="line.460"></a> -<span class="sourceLineNo">461</span> }<a name="line.461"></a> -<span class="sourceLineNo">462</span> return false;<a name="line.462"></a> -<span class="sourceLineNo">463</span> }<a name="line.463"></a> -<span class="sourceLineNo">464</span><a name="line.464"></a> -<span class="sourceLineNo">465</span> public int getClientPort() {<a name="line.465"></a> -<span class="sourceLineNo">466</span> return activeZKServerIndex < 0 || activeZKServerIndex >= clientPortList.size() ? -1<a name="line.466"></a> -<span class="sourceLineNo">467</span> : clientPortList.get(activeZKServerIndex);<a name="line.467"></a> -<span class="sourceLineNo">468</span> }<a name="line.468"></a> -<span class="sourceLineNo">469</span>}<a name="line.469"></a> +<span class="sourceLineNo">228</span> // Setting {min,max}SessionTimeout defaults to be the same as in Zookeeper<a name="line.228"></a> +<span class="sourceLineNo">229</span> server.setMinSessionTimeout(configuration.getInt("hbase.zookeeper.property.minSessionTimeout", -1));<a name="line.229"></a> +<span class="sourceLineNo">230</span> server.setMaxSessionTimeout(configuration.getInt("hbase.zookeeper.property.maxSessionTimeout", -1));<a name="line.230"></a> +<span class="sourceLineNo">231</span> NIOServerCnxnFactory standaloneServerFactory;<a name="line.231"></a> +<span class="sourceLineNo">232</span> while (true) {<a name="line.232"></a> +<span class="sourceLineNo">233</span> try {<a name="line.233"></a> +<span class="sourceLineNo">234</span> standaloneServerFactory = new NIOServerCnxnFactory();<a name="line.234"></a> +<span class="sourceLineNo">235</span> standaloneServerFactory.configure(<a name="line.235"></a> +<span class="sourceLineNo">236</span> new InetSocketAddress(currentClientPort),<a name="line.236"></a> +<span class="sourceLineNo">237</span> configuration.getInt(HConstants.ZOOKEEPER_MAX_CLIENT_CNXNS, 1000));<a name="line.237"></a> +<span class="sourceLineNo">238</span> } catch (BindException e) {<a name="line.238"></a> +<span class="sourceLineNo">239</span> LOG.debug("Failed binding ZK Server to client port: " +<a name="line.239"></a> +<span class="sourceLineNo">240</span> currentClientPort, e);<a name="line.240"></a> +<span class="sourceLineNo">241</span> // We're told to use some port but it's occupied, fail<a name="line.241"></a> +<span class="sourceLineNo">242</span> if (hasValidClientPortInList(i)) {<a name="line.242"></a> +<span class="sourceLineNo">243</span> return -1;<a name="line.243"></a> +<span class="sourceLineNo">244</span> }<a name="line.244"></a> +<span class="sourceLineNo">245</span> // This port is already in use, try to use another.<a name="line.245"></a> +<span class="sourceLineNo">246</span> tentativePort = selectClientPort(tentativePort);<a name="line.246"></a> +<span class="sourceLineNo">247</span> currentClientPort = tentativePort;<a name="line.247"></a> +<span class="sourceLineNo">248</span> continue;<a name="line.248"></a> +<span class="sourceLineNo">249</span> }<a name="line.249"></a> +<span class="sourceLineNo">250</span> break;<a name="line.250"></a> +<span class="sourceLineNo">251</span> }<a name="line.251"></a> +<span class="sourceLineNo">252</span><a name="line.252"></a> +<span class="sourceLineNo">253</span> // Start up this ZK server<a name="line.253"></a> +<span class="sourceLineNo">254</span> standaloneServerFactory.startup(server);<a name="line.254"></a> +<span class="sourceLineNo">255</span> // Runs a 'stat' against the servers.<a name="line.255"></a> +<span class="sourceLineNo">256</span> if (!waitForServerUp(currentClientPort, connectionTimeout)) {<a name="line.256"></a> +<span class="sourceLineNo">257</span> throw new IOException("Waiting for startup of standalone server");<a name="line.257"></a> +<span class="sourceLineNo">258</span> }<a name="line.258"></a> +<span class="sourceLineNo">259</span><a name="line.259"></a> +<span class="sourceLineNo">260</span> // We have selected a port as a client port. Update clientPortList if necessary.<a name="line.260"></a> +<span class="sourceLineNo">261</span> if (clientPortList.size() <= i) { // it is not in the list, add the port<a name="line.261"></a> +<span class="sourceLineNo">262</span> clientPortList.add(currentClientPort);<a name="line.262"></a> +<span class="sourceLineNo">263</span> }<a name="line.263"></a> +<span class="sourceLineNo">264</span> else if (clientPortList.get(i) <= 0) { // the list has invalid port, update with valid port<a name="line.264"></a> +<span class="sourceLineNo">265</span> clientPortList.remove(i);<a name="line.265"></a> +<span class="sourceLineNo">266</span> clientPortList.add(i, currentClientPort);<a name="line.266"></a> +<span class="sourceLineNo">267</span> }<a name="line.267"></a> +<span class="sourceLineNo">268</span><a name="line.268"></a> +<span class="sourceLineNo">269</span> standaloneServerFactoryList.add(standaloneServerFactory);<a name="line.269"></a> +<span class="sourceLineNo">270</span> zooKeeperServers.add(server);<a name="line.270"></a> +<span class="sourceLineNo">271</span> }<a name="line.271"></a> +<span class="sourceLineNo">272</span><a name="line.272"></a> +<span class="sourceLineNo">273</span> // set the first one to be active ZK; Others are backups<a name="line.273"></a> +<span class="sourceLineNo">274</span> activeZKServerIndex = 0;<a name="line.274"></a> +<span class="sourceLineNo">275</span> started = true;<a name="line.275"></a> +<span class="sourceLineNo">276</span> int clientPort = clientPortList.get(activeZKServerIndex);<a name="line.276"></a> +<span class="sourceLineNo">277</span> LOG.info("Started MiniZooKeeperCluster and ran successful 'stat' " +<a name="line.277"></a> +<span class="sourceLineNo">278</span> "on client port=" + clientPort);<a name="line.278"></a> +<span class="sourceLineNo">279</span> return clientPort;<a name="line.279"></a> +<span class="sourceLineNo">280</span> }<a name="line.280"></a> +<span class="sourceLineNo">281</span><a name="line.281"></a> +<span class="sourceLineNo">282</span> private void createDir(File dir) throws IOException {<a name="line.282"></a> +<span class="sourceLineNo">283</span> try {<a name="line.283"></a> +<span class="sourceLineNo">284</span> if (!dir.exists()) {<a name="line.284"></a> +<span class="sourceLineNo">285</span> dir.mkdirs();<a name="line.285"></a> +<span class="sourceLineNo">286</span> }<a name="line.286"></a> +<span class="sourceLineNo">287</span> } catch (SecurityException e) {<a name="line.287"></a> +<span class="sourceLineNo">288</span> throw new IOException("creating dir: " + dir, e);<a name="line.288"></a> +<span class="sourceLineNo">289</span> }<a name="line.289"></a> +<span class="sourceLineNo">290</span> }<a name="line.290"></a> +<span class="sourceLineNo">291</span><a name="line.291"></a> +<span class="sourceLineNo">292</span> /**<a name="line.292"></a> +<span class="sourceLineNo">293</span> * @throws IOException<a name="line.293"></a> +<span class="sourceLineNo">294</span> */<a name="line.294"></a> +<span class="sourceLineNo">295</span> public void shutdown() throws IOException {<a name="line.295"></a> +<span class="sourceLineNo">296</span> // shut down all the zk servers<a name="line.296"></a> +<span class="sourceLineNo">297</span> for (int i = 0; i < standaloneServerFactoryList.size(); i++) {<a name="line.297"></a> +<span class="sourceLineNo">298</span> NIOServerCnxnFactory standaloneServerFactory =<a name="line.298"></a> +<span class="sourceLineNo">299</span> standaloneServerFactoryList.get(i);<a name="line.299"></a> +<span class="sourceLineNo">300</span> int clientPort = clientPortList.get(i);<a name="line.300"></a> +<span class="sourceLineNo">301</span><a name="line.301"></a> +<span class="sourceLineNo">302</span> standaloneServerFactory.shutdown();<a name="line.302"></a> +<span class="sourceLineNo">303</span> if (!waitForServerDown(clientPort, connectionTimeout)) {<a name="line.303"></a> +<span class="sourceLineNo">304</span> throw new IOException("Waiting for shutdown of standalone server");<a name="line.304"></a> +<span class="sourceLineNo">305</span> }<a name="line.305"></a> +<span class="sourceLineNo">306</span> }<a name="line.306"></a> +<span class="sourceLineNo">307</span> standaloneServerFactoryList.clear();<a name="line.307"></a> +<span class="sourceLineNo">308</span><a name="line.308"></a> +<span class="sourceLineNo">309</span> for (ZooKeeperServer zkServer: zooKeeperServers) {<a name="line.309"></a> +<span class="sourceLineNo">310</span> //explicitly close ZKDatabase since ZookeeperServer does not close them<a name="line.310"></a> +<span class="sourceLineNo">311</span> zkServer.getZKDatabase().close();<a name="line.311"></a> +<span class="sourceLineNo">312</span> }<a name="line.312"></a> +<span class="sourceLineNo">313</span> zooKeeperServers.clear();<a name="line.313"></a> +<span class="sourceLineNo">314</span><a name="line.314"></a> +<span class="sourceLineNo">315</span> // clear everything<a name="line.315"></a> +<span class="sourceLineNo">316</span> if (started) {<a name="line.316"></a> +<span class="sourceLineNo">317</span> started = false;<a name="line.317"></a> +<span class="sourceLineNo">318</span> activeZKServerIndex = 0;<a name="line.318"></a> +<span class="sourceLineNo">319</span> clientPortList.clear();<a name="line.319"></a> +<span class="sourceLineNo">320</span> LOG.info("Shutdown MiniZK cluster with all ZK servers");<a name="line.320"></a> +<span class="sourceLineNo">321</span> }<a name="line.321"></a> +<span class="sourceLineNo">322</span> }<a name="line.322"></a> +<span class="sourceLineNo">323</span><a name="line.323"></a> +<span class="sourceLineNo">324</span> /**@return clientPort return clientPort if there is another ZK backup can run<a name="line.324"></a> +<span class="sourceLineNo">325</span> * when killing the current active; return -1, if there is no backups.<a name="line.325"></a> +<span class="sourceLineNo">326</span> * @throws IOException<a name="line.326"></a> +<span class="sourceLineNo">327</span> * @throws InterruptedException<a name="line.327"></a> +<span class="sourceLineNo">328</span> */<a name="line.328"></a> +<span class="sourceLineNo">329</span> public int killCurrentActiveZooKeeperServer() throws IOException,<a name="line.329"></a> +<span class="sourceLineNo">330</span> InterruptedException {<a name="line.330"></a> +<span class="sourceLineNo">331</span> if (!started || activeZKServerIndex < 0) {<a name="line.331"></a> +<span class="sourceLineNo">332</span> return -1;<a name="line.332"></a> +<span class="sourceLineNo">333</span> }<a name="line.333"></a> +<span class="sourceLineNo">334</span><a name="line.334"></a> +<span class="sourceLineNo">335</span> // Shutdown the current active one<a name="line.335"></a> +<span class="sourceLineNo">336</span> NIOServerCnxnFactory standaloneServerFactory =<a name="line.336"></a> +<span class="sourceLineNo">337</span> standaloneServerFactoryList.get(activeZKServerIndex);<a name="line.337"></a> +<span class="sourceLineNo">338</span> int clientPort = clientPortList.get(activeZKServerIndex);<a name="line.338"></a> +<span class="sourceLineNo">339</span><a name="line.339"></a> +<span class="sourceLineNo">340</span> standaloneServerFactory.shutdown();<a name="line.340"></a> +<span class="sourceLineNo">341</span> if (!waitForServerDown(clientPort, connectionTimeout)) {<a name="line.341"></a> +<span class="sourceLineNo">342</span> throw new IOException("Waiting for shutdown of standalone server");<a name="line.342"></a> +<span class="sourceLineNo">343</span> }<a name="line.343"></a> +<span class="sourceLineNo">344</span><a name="line.344"></a> +<span class="sourceLineNo">345</span> zooKeeperServers.get(activeZKServerIndex).getZKDatabase().close();<a name="line.345"></a> +<span class="sourceLineNo">346</span><a name="line.346"></a> +<span class="sourceLineNo">347</span> // remove the current active zk server<a name="line.347"></a> +<span class="sourceLineNo">348</span> standaloneServerFactoryList.remove(activeZKServerIndex);<a name="line.348"></a> +<span class="sourceLineNo">349</span> clientPortList.remove(activeZKServerIndex);<a name="line.349"></a> +<span class="sourceLineNo">350</span> zooKeeperServers.remove(activeZKServerIndex);<a name="line.350"></a> +<span class="sourceLineNo">351</span> LOG.info("Kill the current active ZK servers in the cluster " +<a name="line.351"></a> +<span class="sourceLineNo">352</span> "on client port: " + clientPort);<a name="line.352"></a> +<span class="sourceLineNo">353</span><a name="line.353"></a> +<span class="sourceLineNo">354</span> if (standaloneServerFactoryList.isEmpty()) {<a name="line.354"></a> +<span class="sourceLineNo">355</span> // there is no backup servers;<a name="line.355"></a> +<span class="sourceLineNo">356</span> return -1;<a name="line.356"></a> +<span class="sourceLineNo">357</span> }<a name="line.357"></a> +<span class="sourceLineNo">358</span> clientPort = clientPortList.get(activeZKServerIndex);<a name="line.358"></a> +<span class="sourceLineNo">359</span> LOG.info("Activate a backup zk server in the cluster " +<a name="line.359"></a> +<span class="sourceLineNo">360</span> "on client port: " + clientPort);<a name="line.360"></a> +<span class="sourceLineNo">361</span> // return the next back zk server's port<a name="line.361"></a> +<span class="sourceLineNo">362</span> return clientPort;<a name="line.362"></a> +<span class="sourceLineNo">363</span> }<a name="line.363"></a> +<span class="sourceLineNo">364</span><a name="line.364"></a> +<span class="sourceLineNo">365</span> /**<a name="line.365"></a> +<span class="sourceLineNo">366</span> * Kill one back up ZK servers<a name="line.366"></a> +<span class="sourceLineNo">367</span> * @throws IOException<a name="line.367"></a> +<span class="sourceLineNo">368</span> * @throws InterruptedException<a name="line.368"></a> +<span class="sourceLineNo">369</span> */<a name="line.369"></a> +<span class="sourceLineNo">370</span> public void killOneBackupZooKeeperServer() throws IOException,<a name="line.370"></a> +<span class="sourceLineNo">371</span> InterruptedException {<a name="line.371"></a> +<span class="sourceLineNo">372</span> if (!started || activeZKServerIndex < 0 ||<a name="line.372"></a> +<span class="sourceLineNo">373</span> standaloneServerFactoryList.size() <= 1) {<a name="line.373"></a> +<span class="sourceLineNo">374</span> return ;<a name="line.374"></a> +<span class="sourceLineNo">375</span> }<a name="line.375"></a> +<span class="sourceLineNo">376</span><a name="line.376"></a> +<span class="sourceLineNo">377</span> int backupZKServerIndex = activeZKServerIndex+1;<a name="line.377"></a> +<span class="sourceLineNo">378</span> // Shutdown the current active one<a name="line.378"></a> +<span class="sourceLineNo">379</span> NIOServerCnxnFactory standaloneServerFactory =<a name="line.379"></a> +<span class="sourceLineNo">380</span> standaloneServerFactoryList.get(backupZKServerIndex);<a name="line.380"></a> +<span class="sourceLineNo">381</span> int clientPort = clientPortList.get(backupZKServerIndex);<a name="line.381"></a> +<span class="sourceLineNo">382</span><a name="line.382"></a> +<span class="sourceLineNo">383</span> standaloneServerFactory.shutdown();<a name="line.383"></a> +<span class="sourceLineNo">384</span> if (!waitForServerDown(clientPort, connectionTimeout)) {<a name="line.384"></a> +<span class="sourceLineNo">385</span> throw new IOException("Waiting for shutdown of standalone server");<a name="line.385"></a> +<span class="sourceLineNo">386</span> }<a name="line.386"></a> +<span class="sourceLineNo">387</span><a name="line.387"></a> +<span class="sourceLineNo">388</span> zooKeeperServers.get(backupZKServerIndex).getZKDatabase().close();<a name="line.388"></a> +<span class="sourceLineNo">389</span><a name="line.389"></a> +<span class="sourceLineNo">390</span> // remove this backup zk server<a name="line.390"></a> +<span class="sourceLineNo">391</span> standaloneServerFactoryList.remove(backupZKServerIndex);<a name="line.391"></a> +<span class="sourceLineNo">392</span> clientPortList.remove(backupZKServerIndex);<a name="line.392"></a> +<span class="sourceLineNo">393</span> zooKeeperServers.remove(backupZKServerIndex);<a name="line.393"></a> +<span class="sourceLineNo">394</span> LOG.info("Kill one backup ZK servers in the cluster " +<a name="line.394"></a> +<span class="sourceLineNo">395</span> "on client port: " + clientPort);<a name="line.395"></a> +<span class="sourceLineNo">396</span> }<a name="line.396"></a> +<span class="sourceLineNo">397</span><a name="line.397"></a> +<span class="sourceLineNo">398</span> // XXX: From o.a.zk.t.ClientBase<a name="line.398"></a> +<span class="sourceLineNo">399</span> private static boolean waitForServerDown(int port, long timeout) throws IOException {<a name="line.399"></a> +<span class="sourceLineNo">400</span> long start = System.currentTimeMillis();<a name="line.400"></a> +<span class="sourceLineNo">401</span> while (true) {<a name="line.401"></a> +<span class="sourceLineNo">402</span> try {<a name="line.402"></a> +<span class="sourceLineNo">403</span> Socket sock = new Socket("localhost", port);<a name="line.403"></a> +<span class="sourceLineNo">404</span> try {<a name="line.404"></a> +<span class="sourceLineNo">405</span> OutputStream outstream = sock.getOutputStream();<a name="line.405"></a> +<span class="sourceLineNo">406</span> outstream.write("stat".getBytes());<a name="line.406"></a> +<span class="sourceLineNo">407</span> outstream.flush();<a name="line.407"></a> +<span class="sourceLineNo">408</span> } finally {<a name="line.408"></a> +<span class="sourceLineNo">409</span> sock.close();<a name="line.409"></a> +<span class="sourceLineNo">410</span> }<a name="line.410"></a> +<span class="sourceLineNo">411</span> } catch (IOException e) {<a name="line.411"></a> +<span class="sourceLineNo">412</span> return true;<a name="line.412"></a> +<span class="sourceLineNo">413</span> }<a name="line.413"></a> +<span class="sourceLineNo">414</span><a name="line.414"></a> +<span class="sourceLineNo">415</span> if (System.currentTimeMillis() > start + timeout) {<a name="line.415"></a> +<span class="sourceLineNo">416</span> break;<a name="line.416"></a> +<span class="sourceLineNo">417</span> }<a name="line.417"></a> +<span class="sourceLineNo">418</span> try {<a name="line.418"></a> +<span class="sourceLineNo">419</span> Thread.sleep(250);<a name="line.419"></a> +<span class="sourceLineNo">420</span> } catch (InterruptedException e) {<a name="line.420"></a> +<span class="sourceLineNo">421</span> throw (InterruptedIOException)new InterruptedIOException().initCause(e);<a name="line.421"></a> +<span class="sourceLineNo">422</span> }<a name="line.422"></a> +<span class="sourceLineNo">423</span> }<a name="line.423"></a> +<span class="sourceLineNo">424</span> return false;<a name="line.424"></a> +<span class="sourceLineNo">425</span> }<a name="line.425"></a> +<span class="sourceLineNo">426</span><a name="line.426"></a> +<span class="sourceLineNo">427</span> // XXX: From o.a.zk.t.ClientBase<a name="line.427"></a> +<span class="sourceLineNo">428</span> private static boolean waitForServerUp(int port, long timeout) throws IOException {<a name="line.428"></a> +<span class="sourceLineNo">429</span> long start = System.currentTimeMillis();<a name="line.429"></a> +<span class="sourceLineNo">430</span> while (true) {<a name="line.430"></a> +<span class="sourceLineNo">431</span> try {<a name="line.431"></a> +<span class="sourceLineNo">432</span> Socket sock = new Socket("localhost", port);<a name="line.432"></a> +<span class="sourceLineNo">433</span> BufferedReader reader = null;<a name="line.433"></a> +<span class="sourceLineNo">434</span> try {<a name="line.434"></a> +<span class="sourceLineNo">435</span> OutputStream outstream = sock.getOutputStream();<a name="line.435"></a> +<span class="sourceLineNo">436</span> outstream.write("stat".getBytes());<a name="line.436"></a> +<span class="sourceLineNo">437</span> outstream.flush();<a name="line.437"></a> +<span class="sourceLineNo">438</span><a name="line.438"></a> +<span class="sourceLineNo">439</span> Reader isr = new InputStreamReader(sock.getInputStream());<a name="line.439"></a> +<span class="sourceLineNo">440</span> reader = new BufferedReader(isr);<a name="line.440"></a> +<span class="sourceLineNo">441</span> String line = reader.readLine();<a name="line.441"></a> +<span class="sourceLineNo">442</span> if (line != null && line.startsWith("Zookeeper version:")) {<a name="line.442"></a> +<span class="sourceLineNo">443</span> return true;<a name="line.443"></a> +<span class="sourceLineNo">444</span> }<a name="line.444"></a> +<span class="sourceLineNo">445</span> } finally {<a name="line.445"></a> +<span class="sourceLineNo">446</span> sock.close();<a name="line.446"></a> +<span class="sourceLineNo">447</span> if (reader != null) {<a name="line.447"></a> +<span class="sourceLineNo">448</span> reader.close();<a name="line.448"></a> +<span class="sourceLineNo">449</span> }<a name="line.449"></a> +<span class="sourceLineNo">450</span> }<a name="line.450"></a> +<span class="sourceLineNo">451</span> } catch (IOException e) {<a name="line.451"></a> +<span class="sourceLineNo">452</span> // ignore as this is expected<a name="line.452"></a> +<span class="sourceLineNo">453</span> LOG.info("server localhost:" + port + " not up " + e);<a name="line.453"></a> +<span class="sourceLineNo">454</span> }<a name="line.454"></a> +<span class="sourceLineNo">455</span><a name="line.455"></a> +<span class="sourceLineNo">456</span> if (System.currentTimeMillis() > start + timeout) {<a name="line.456"></a> +<span class="sourceLineNo">457</span> break;<a name="line.457"></a> +<span class="sourceLineNo">458</span> }<a name="line.458"></a> +<span class="sourceLineNo">459</span> try {<a name="line.459"></a> +<span class="sourceLineNo">460</span> Thread.sleep(250);<a name="line.460"></a> +<span class="sourceLineNo">461</span> } catch (InterruptedException e) {<a name="line.461"></a> +<span class="sourceLineNo">462</span> throw (InterruptedIOException)new InterruptedIOException().initCause(e);<a name="line.462"></a> +<span class="sourceLineNo">463</span> }<a name="line.463"></a> +<span class="sourceLineNo">464</span> }<a name="line.464"></a> +<span class="sourceLineNo">465</span> return false;<a name="line.465"></a> +<span class="sourceLineNo">466</span> }<a name="line.466"></a> +<span class="sourceLineNo">467</span><a name="line.467"></a> +<span class="sourceLineNo">468</span> public int getClientPort() {<a name="line.468"></a> +<span class="sourceLineNo">469</span> return activeZKServerIndex < 0 || activeZKServerIndex >= clientPortList.size() ? -1<a name="line.469"></a> +<span class="sourceLineNo">470</span> : clientPortList.get(activeZKServerIndex);<a name="line.470"></a> +<span class="sourceLineNo">471</span> }<a name="line.471"></a> +<span class="sourceLineNo">472</span>}<a name="line.472"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6f0c8299/book.html ---------------------------------------------------------------------- diff --git a/book.html b/book.html index 43c9f04..0e33d48 100644 --- a/book.html +++ b/book.html @@ -35086,7 +35086,7 @@ The server will return cellblocks compressed using this same compressor as long <div id="footer"> <div id="footer-text"> Version 3.0.0-SNAPSHOT<br> -Last updated 2017-08-30 14:29:43 UTC +Last updated 2017-08-31 14:29:36 UTC </div> </div> </body> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6f0c8299/bulk-loads.html ---------------------------------------------------------------------- diff --git a/bulk-loads.html b/bulk-loads.html index 5ed792a..c49eddb 100644 --- a/bulk-loads.html +++ b/bulk-loads.html @@ -7,7 +7,7 @@ <head> <meta charset="UTF-8" /> <meta name="viewport" content="width=device-width, initial-scale=1.0" /> - <meta name="Date-Revision-yyyymmdd" content="20170830" /> + <meta name="Date-Revision-yyyymmdd" content="20170831" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Bulk Loads in Apache HBase (TM) @@ -311,7 +311,7 @@ under the License. --> <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved. - <li id="publishDate" class="pull-right">Last Published: 2017-08-30</li> + <li id="publishDate" class="pull-right">Last Published: 2017-08-31</li> </p> </div> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6f0c8299/checkstyle-aggregate.html ---------------------------------------------------------------------- diff --git a/checkstyle-aggregate.html b/checkstyle-aggregate.html index fb29f2e..14a6387 100644 --- a/checkstyle-aggregate.html +++ b/checkstyle-aggregate.html @@ -7,7 +7,7 @@ <head> <meta charset="UTF-8" /> <meta name="viewport" content="width=device-width, initial-scale=1.0" /> - <meta name="Date-Revision-yyyymmdd" content="20170830" /> + <meta name="Date-Revision-yyyymmdd" content="20170831" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Checkstyle Results @@ -289,7 +289,7 @@ 2038 0 0 -12893 +12897

Files

@@ -607,7 +607,7 @@ - + @@ -6922,7 +6922,7 @@ - + @@ -7159,7 +7159,7 @@
  • max: "100"
  • ignorePattern: "^package.*|^import.*|a href|href|http://|https://|ftp://|org.apache.thrift.|com.google.protobuf.|hbase.protobuf.generated"
- + @@ -12701,14 +12701,26 @@ - + + + + + + + + + + + + + -
org/apache/hadoop/hbase/backup/BackupRestoreConstants.java 0 03
5
org/apache/hadoop/hbase/backup/BackupTableInfo.java 0org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.java 0 013
15
org/apache/hadoop/hbase/zookeeper/RecoverableZooKeeper.java 010381042  Error
 Error sizes LineLengthLine is longer than 100 characters (found 105).Line is longer than 100 characters (found 109). 93
 Error sizes LineLengthLine is longer than 100 characters (found 118).94
 ErrorsizesLineLengthLine is longer than 100 characters (found 105).97
 ErrorsizesLineLength Line is longer than 100 characters (found 122).105
+109

org/apache/hadoop/hbase/backup/BackupTableInfo.java

@@ -12912,7 +12924,7 @@ -
blocks NeedBraces 'if' construct must use '{}'s.185
+194

org/apache/hadoop/hbase/backup/RestoreJob.java

@@ -13176,349 +13188,349 @@ - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + - + -
indentation Indentation 'case' child have incorrect indentation level 4, expected level should be 6.210
212
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.211
213
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.212
214
 Error indentation Indentation 'case' child have incorrect indentation level 4, expected level should be 6.213
215
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.214
216
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.215
217
 Error indentation Indentation 'case' child have incorrect indentation level 4, expected level should be 6.216
218
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.217
219
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.218
220
 Error indentation Indentation 'case' child have incorrect indentation level 4, expected level should be 6.219
221
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.220
222
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.221
223
 Error indentation Indentation 'case' child have incorrect indentation level 4, expected level should be 6.222
224
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.223
225
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.224
226
 Error indentation Indentation 'case' child have incorrect indentation level 4, expected level should be 6.225
227
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.226
228
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.227
229
 Error indentation Indentation 'case' child have incorrect indentation level 4, expected level should be 6.228
230
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.229
231
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.230
232
 Error indentation Indentation 'case' child have incorrect indentation level 4, expected level should be 6.231
233
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.232
234
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.233
235
 Error indentation Indentation 'case' child have incorrect indentation level 4, expected level should be 6.234
236
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.235
237
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.236
238
 Error indentation Indentation 'case' child have incorrect indentation level 4, expected level should be 6.237
239
 Error indentation Indentation 'case' child have incorrect indentation level 4, expected level should be 6.238
240
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.239
241
 Error indentation Indentation 'block' child have incorrect indentation level 6, expected level should be 8.240
242
 Error blocks NeedBraces 'if' construct must use '{}'s.246
248
 Error blocks NeedBraces 'if' construct must use '{}'s.347
355
 Error blocks NeedBraces 'if' construct must use '{}'s.358
366
 Error blocks EmptyBlock Must have at least one statement.510
520
 Error sizes LineLength Line is longer than 100 characters (found 112).561
571
 Error blocks NeedBraces 'if' construct must use '{}'s.769
779
 Error blocks NeedBraces 'if' construct must use '{}'s.777
787
 Error blocks NeedBraces 'if' construct must use '{}'s.804
814
 Error blocks NeedBraces 'if' construct must use '{}'s.815
825
 Error blocks NeedBraces 'if' construct must use '{}'s.833
843
 Error indentation Indentation 'case' child have incorrect indentation level 6, expected level should be 8.885
895
 Error indentation Indentation 'block' child have incorrect indentation level 8, expected level should be 10.886
896
 Error indentation Indentation 'block' child have incorrect indentation level 8, expected level should be 10.887
897
 Error indentation Indentation 'case' child have incorrect indentation level 6, expected level should be 8.888
898
 Error indentation Indentation 'block' child have incorrect indentation level 8, expected level should be 10.889
899
 Error indentation Indentation 'block' child have incorrect indentation level 8, expected level should be 10.890
900
 Error indentation Indentation 'case' child have incorrect indentation level 6, expected level should be 8.891
901
 Error indentation Indentation 'block' child have incorrect indentation level 8, expected level should be 10.892
902
 Error indentation Indentation 'block' child have incorrect indentation level 8, expected level should be 10.893
903
 Error indentation Indentation 'case' child have incorrect indentation level 6, expected level should be 8.894
904
 Error indentation Indentation 'block' child have incorrect indentation level 8, expected level should be 10.895
905
 Error indentation Indentation 'block' child have incorrect indentation level 8, expected level should be 10.896
906
 Error indentation Indentation 'case' child have incorrect indentation level 6, expected level should be 8.897
907
 Error indentation Indentation 'block' child have incorrect indentation level 8, expected level should be 10.898
908
 Error indentation Indentation 'block' child have incorrect indentation level 8, expected level should be 10.899
909
 Error indentation Indentation 'case' child have incorrect indentation level 6, expected level should be 8.900
910
 Error indentation Indentation 'block' child have incorrect indentation level 8, expected level should be 10.901
+911

org/apache/hadoop/hbase/backup/impl/BackupManager.java

@@ -95190,34 +95202,46 @@ + + + + + + + + + + + + - + - + - + - + -
199
 ErrorsizesLineLengthLine is longer than 100 characters (found 106).229
 ErrorsizesLineLengthLine is longer than 100 characters (found 106).230
 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description.290
293
 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description.323
326
 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description.324
327
 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description.364
367
 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description.365
+368

org/apache/hadoop/hbase/zookeeper/RecoverableZooKeeper.java

@@ -96649,7 +96673,7 @@ The Apache Software Foundation. All rights reserved. -
  • Last Published: 2017-08-30
    • +
  • Last Published: 2017-08-31