Published site at 971f5350e81591e9360677f3617a399f453b6b96.
Project: http://git-wip-us.apache.org/repos/asf/hbase-site/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase-site/commit/2bbea48a Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/2bbea48a Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/2bbea48a Branch: refs/heads/asf-site Commit: 2bbea48a6732dc8fabe7a4816dffc755a8b145d7 Parents: 6f3be57 Author: jenkins <bui...@apache.org> Authored: Sun May 6 14:47:39 2018 +0000 Committer: jenkins <bui...@apache.org> Committed: Sun May 6 14:47:39 2018 +0000 ---------------------------------------------------------------------- acid-semantics.html | 4 +- apache_hbase_reference_guide.pdf | 4 +- book.html | 2 +- bulk-loads.html | 4 +- checkstyle-aggregate.html | 40 +++---- coc.html | 4 +- dependencies.html | 4 +- dependency-convergence.html | 4 +- dependency-info.html | 4 +- dependency-management.html | 4 +- devapidocs/constant-values.html | 6 +- .../org/apache/hadoop/hbase/Version.html | 6 +- .../HRegionServer.CompactionChecker.html | 106 +++++++++---------- .../HRegionServer.MovedRegionInfo.html | 106 +++++++++---------- .../HRegionServer.MovedRegionsCleaner.html | 106 +++++++++---------- .../HRegionServer.PeriodicMemStoreFlusher.html | 106 +++++++++---------- .../hbase/regionserver/HRegionServer.html | 106 +++++++++---------- downloads.html | 4 +- export_control.html | 4 +- index.html | 4 +- integration.html | 4 +- issue-tracking.html | 4 +- license.html | 4 +- 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 +- 39 files changed, 352 insertions(+), 352 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/acid-semantics.html ---------------------------------------------------------------------- diff --git a/acid-semantics.html b/acid-semantics.html index 5349f3f..6116619 100644 --- a/acid-semantics.html +++ b/acid-semantics.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="20180505" /> + <meta name="Date-Revision-yyyymmdd" content="20180506" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Apache HBase (TM) ACID Properties @@ -601,7 +601,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: 2018-05-05</li> + <li id="publishDate" class="pull-right">Last Published: 2018-05-06</li> </p> </div> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/apache_hbase_reference_guide.pdf ---------------------------------------------------------------------- diff --git a/apache_hbase_reference_guide.pdf b/apache_hbase_reference_guide.pdf index 6add424..2092c90 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:20180505143250+00'00') -/CreationDate (D:20180505144900+00'00') +/ModDate (D:20180506142957+00'00') +/CreationDate (D:20180506144459+00'00') >> endobj 2 0 obj http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/book.html ---------------------------------------------------------------------- diff --git a/book.html b/book.html index e922745..4d6ad9d 100644 --- a/book.html +++ b/book.html @@ -37873,7 +37873,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 2018-05-05 14:32:50 UTC +Last updated 2018-05-06 14:29:57 UTC </div> </div> </body> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/bulk-loads.html ---------------------------------------------------------------------- diff --git a/bulk-loads.html b/bulk-loads.html index 63ab198..04b6395 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="20180505" /> + <meta name="Date-Revision-yyyymmdd" content="20180506" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Bulk Loads in Apache HBase (TM) @@ -306,7 +306,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: 2018-05-05</li> + <li id="publishDate" class="pull-right">Last Published: 2018-05-06</li> </p> </div> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/checkstyle-aggregate.html ---------------------------------------------------------------------- diff --git a/checkstyle-aggregate.html b/checkstyle-aggregate.html index d807e05..1b5961d 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="20180505" /> + <meta name="Date-Revision-yyyymmdd" content="20180506" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Checkstyle Results</title> <link rel="stylesheet" href="./css/apache-maven-fluido-1.5-HBASE.min.css" /> @@ -10322,12 +10322,12 @@ <td><a class="externalLink" href="http://checkstyle.sourceforge.net/config_javadoc.html#JavadocTagContinuationIndentation">JavadocTagContinuationIndentation</a> <ul> <li>offset: <tt>"2"</tt></li></ul></td> -<td>797</td> +<td>783</td> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td></tr> <tr class="b"> <td></td> <td><a class="externalLink" href="http://checkstyle.sourceforge.net/config_javadoc.html#NonEmptyAtclauseDescription">NonEmptyAtclauseDescription</a></td> -<td>3822</td> +<td>3836</td> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td></tr> <tr class="a"> <td>misc</td> @@ -14536,7 +14536,7 @@ <tr class="b"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 26 has parse error. Missed HTML close tag 'arg'. Sometimes it means that close tag missed for one of previous tags.</td> <td>44</td></tr></table></div> <div class="section"> @@ -15172,7 +15172,7 @@ <tr class="a"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 4 has parse error. Missed HTML close tag 'pre'. Sometimes it means that close tag missed for one of previous tags.</td> <td>59</td></tr></table></div> <div class="section"> @@ -16927,7 +16927,7 @@ <tr class="b"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 19 has parse error. Details: no viable alternative at input '<code>\n * List<Future<' while parsing HTML_TAG</td> <td>167</td></tr></table></div> <div class="section"> @@ -19855,7 +19855,7 @@ <tr class="a"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 2 has parse error. Unrecognized error from ANTLR parser: null</td> <td>83</td></tr> <tr class="b"> @@ -33802,7 +33802,7 @@ <tr class="a"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 37 has parse error. Details: no viable alternative at input '<ColumnFamily,' while parsing HTML_ELEMENT</td> <td>29</td></tr></table></div> <div class="section"> @@ -50098,7 +50098,7 @@ <tr class="b"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 24 has parse error. Details: no viable alternative at input '<key,' while parsing HTML_ELEMENT</td> <td>25</td></tr> <tr class="a"> @@ -53686,7 +53686,7 @@ <tr class="a"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 2 has parse error. Unrecognized error from ANTLR parser: null</td> <td>587</td></tr> <tr class="b"> @@ -73297,7 +73297,7 @@ <tr class="b"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 60 has parse error. Missed HTML close tag 'Comparable'. Sometimes it means that close tag missed for one of previous tags.</td> <td>29</td></tr> <tr class="a"> @@ -77479,7 +77479,7 @@ <tr class="b"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 0 has parse error. Unrecognized error from ANTLR parser: null</td> <td>74</td></tr> <tr class="a"> @@ -81384,13 +81384,13 @@ <td>blocks</td> <td>EmptyBlock</td> <td>Must have at least one statement.</td> -<td>1069</td></tr> +<td>1060</td></tr> <tr class="b"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>blocks</td> <td>NeedBraces</td> <td>'if' construct must use '{}'s.</td> -<td>1082</td></tr> +<td>1073</td></tr> <tr class="a"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>blocks</td> @@ -87409,7 +87409,7 @@ <tr class="a"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 33 has parse error. Missed HTML close tag 'number'. Sometimes it means that close tag missed for one of previous tags.</td> <td>127</td></tr> <tr class="b"> @@ -115957,7 +115957,7 @@ <tr class="b"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 23 has parse error. Details: no viable alternative at input '<expected,' while parsing HTML_ELEMENT</td> <td>143</td></tr> <tr class="a"> @@ -116161,7 +116161,7 @@ <tr class="b"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 78 has parse error. Details: no viable alternative at input '<Object>, Map<String,' while parsing HTML_TAG</td> <td>33</td></tr> <tr class="a"> @@ -116761,7 +116761,7 @@ <tr class="a"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 35 has parse error. Missed HTML close tag 'index'. Sometimes it means that close tag missed for one of previous tags.</td> <td>823</td></tr> <tr class="b"> @@ -120574,7 +120574,7 @@ <tr class="a"> <td><img src="images/icon_error_sml.gif" alt="" /> Error</td> <td>javadoc</td> -<td>JavadocTagContinuationIndentation</td> +<td>NonEmptyAtclauseDescription</td> <td>Javadoc comment at column 58 has parse error. Details: no viable alternative at input '<byte[' while parsing HTML_ELEMENT</td> <td>426</td></tr> <tr class="b"> @@ -123409,7 +123409,7 @@ <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved. - <li id="publishDate" class="pull-right">Last Published: 2018-05-05</li> + <li id="publishDate" class="pull-right">Last Published: 2018-05-06</li> </p> </div> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/coc.html ---------------------------------------------------------------------- diff --git a/coc.html b/coc.html index c8ad6c7..eaef90d 100644 --- a/coc.html +++ b/coc.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="20180505" /> + <meta name="Date-Revision-yyyymmdd" content="20180506" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Code of Conduct Policy @@ -375,7 +375,7 @@ email to <a class="externalLink" href="mailto:priv...@hbase.apache.org">the priv <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved. - <li id="publishDate" class="pull-right">Last Published: 2018-05-05</li> + <li id="publishDate" class="pull-right">Last Published: 2018-05-06</li> </p> </div> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/dependencies.html ---------------------------------------------------------------------- diff --git a/dependencies.html b/dependencies.html index bf02801..16b9067 100644 --- a/dependencies.html +++ b/dependencies.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="20180505" /> + <meta name="Date-Revision-yyyymmdd" content="20180506" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Project Dependencies</title> <link rel="stylesheet" href="./css/apache-maven-fluido-1.5-HBASE.min.css" /> @@ -440,7 +440,7 @@ <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved. - <li id="publishDate" class="pull-right">Last Published: 2018-05-05</li> + <li id="publishDate" class="pull-right">Last Published: 2018-05-06</li> </p> </div> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/dependency-convergence.html ---------------------------------------------------------------------- diff --git a/dependency-convergence.html b/dependency-convergence.html index 5f2f21f..2e3f5f3 100644 --- a/dependency-convergence.html +++ b/dependency-convergence.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="20180505" /> + <meta name="Date-Revision-yyyymmdd" content="20180506" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Reactor Dependency Convergence</title> <link rel="stylesheet" href="./css/apache-maven-fluido-1.5-HBASE.min.css" /> @@ -1105,7 +1105,7 @@ <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved. - <li id="publishDate" class="pull-right">Last Published: 2018-05-05</li> + <li id="publishDate" class="pull-right">Last Published: 2018-05-06</li> </p> </div> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/dependency-info.html ---------------------------------------------------------------------- diff --git a/dependency-info.html b/dependency-info.html index 703c94f..3aed04a 100644 --- a/dependency-info.html +++ b/dependency-info.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="20180505" /> + <meta name="Date-Revision-yyyymmdd" content="20180506" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Dependency Information</title> <link rel="stylesheet" href="./css/apache-maven-fluido-1.5-HBASE.min.css" /> @@ -313,7 +313,7 @@ <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved. - <li id="publishDate" class="pull-right">Last Published: 2018-05-05</li> + <li id="publishDate" class="pull-right">Last Published: 2018-05-06</li> </p> </div> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/dependency-management.html ---------------------------------------------------------------------- diff --git a/dependency-management.html b/dependency-management.html index 59ef175..2a9ffd4 100644 --- a/dependency-management.html +++ b/dependency-management.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="20180505" /> + <meta name="Date-Revision-yyyymmdd" content="20180506" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Project Dependency Management</title> <link rel="stylesheet" href="./css/apache-maven-fluido-1.5-HBASE.min.css" /> @@ -969,7 +969,7 @@ <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved. - <li id="publishDate" class="pull-right">Last Published: 2018-05-05</li> + <li id="publishDate" class="pull-right">Last Published: 2018-05-06</li> </p> </div> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/devapidocs/constant-values.html ---------------------------------------------------------------------- diff --git a/devapidocs/constant-values.html b/devapidocs/constant-values.html index b81f234..22caf4d 100644 --- a/devapidocs/constant-values.html +++ b/devapidocs/constant-values.html @@ -3768,21 +3768,21 @@ <!-- --> </a><code>public static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td> <td><code><a href="org/apache/hadoop/hbase/Version.html#date">date</a></code></td> -<td class="colLast"><code>"Sat May 5 14:43:16 UTC 2018"</code></td> +<td class="colLast"><code>"Sun May 6 14:39:27 UTC 2018"</code></td> </tr> <tr class="rowColor"> <td class="colFirst"><a name="org.apache.hadoop.hbase.Version.revision"> <!-- --> </a><code>public static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td> <td><code><a href="org/apache/hadoop/hbase/Version.html#revision">revision</a></code></td> -<td class="colLast"><code>"acd0d1e446c164d9c54bfb461b2d449c8d717c07"</code></td> +<td class="colLast"><code>"971f5350e81591e9360677f3617a399f453b6b96"</code></td> </tr> <tr class="altColor"> <td class="colFirst"><a name="org.apache.hadoop.hbase.Version.srcChecksum"> <!-- --> </a><code>public static final <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a></code></td> <td><code><a href="org/apache/hadoop/hbase/Version.html#srcChecksum">srcChecksum</a></code></td> -<td class="colLast"><code>"ad489a437d1ef798b4c0329dd68b451a"</code></td> +<td class="colLast"><code>"ffc5680715ed56f21d5623cc15a65008"</code></td> </tr> <tr class="rowColor"> <td class="colFirst"><a name="org.apache.hadoop.hbase.Version.url"> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html b/devapidocs/src-html/org/apache/hadoop/hbase/Version.html index 534acbb..fa2ce6e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/Version.html @@ -16,11 +16,11 @@ <span class="sourceLineNo">008</span>@InterfaceAudience.Private<a name="line.8"></a> <span class="sourceLineNo">009</span>public class Version {<a name="line.9"></a> <span class="sourceLineNo">010</span> public static final String version = "3.0.0-SNAPSHOT";<a name="line.10"></a> -<span class="sourceLineNo">011</span> public static final String revision = "acd0d1e446c164d9c54bfb461b2d449c8d717c07";<a name="line.11"></a> +<span class="sourceLineNo">011</span> public static final String revision = "971f5350e81591e9360677f3617a399f453b6b96";<a name="line.11"></a> <span class="sourceLineNo">012</span> public static final String user = "jenkins";<a name="line.12"></a> -<span class="sourceLineNo">013</span> public static final String date = "Sat May 5 14:43:16 UTC 2018";<a name="line.13"></a> +<span class="sourceLineNo">013</span> public static final String date = "Sun May 6 14:39:27 UTC 2018";<a name="line.13"></a> <span class="sourceLineNo">014</span> public static final String url = "git://jenkins-websites1.apache.org/home/jenkins/jenkins-slave/workspace/hbase_generate_website/hbase";<a name="line.14"></a> -<span class="sourceLineNo">015</span> public static final String srcChecksum = "ad489a437d1ef798b4c0329dd68b451a";<a name="line.15"></a> +<span class="sourceLineNo">015</span> public static final String srcChecksum = "ffc5680715ed56f21d5623cc15a65008";<a name="line.15"></a> <span class="sourceLineNo">016</span>}<a name="line.16"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html index d2efdfe..9644187 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html @@ -1060,58 +1060,58 @@ <span class="sourceLineNo">1052</span> if (this.storefileRefresher != null) this.storefileRefresher.cancel(true);<a name="line.1052"></a> <span class="sourceLineNo">1053</span> sendShutdownInterrupt();<a name="line.1053"></a> <span class="sourceLineNo">1054</span><a name="line.1054"></a> -<span class="sourceLineNo">1055</span> // Stop the quota manager<a name="line.1055"></a> -<span class="sourceLineNo">1056</span> if (rsQuotaManager != null) {<a name="line.1056"></a> -<span class="sourceLineNo">1057</span> rsQuotaManager.stop();<a name="line.1057"></a> +<span class="sourceLineNo">1055</span> // Stop the snapshot and other procedure handlers, forcefully killing all running tasks<a name="line.1055"></a> +<span class="sourceLineNo">1056</span> if (rspmHost != null) {<a name="line.1056"></a> +<span class="sourceLineNo">1057</span> rspmHost.stop(this.abortRequested || this.killed);<a name="line.1057"></a> <span class="sourceLineNo">1058</span> }<a name="line.1058"></a> -<span class="sourceLineNo">1059</span> if (rsSpaceQuotaManager != null) {<a name="line.1059"></a> -<span class="sourceLineNo">1060</span> rsSpaceQuotaManager.stop();<a name="line.1060"></a> -<span class="sourceLineNo">1061</span> rsSpaceQuotaManager = null;<a name="line.1061"></a> -<span class="sourceLineNo">1062</span> }<a name="line.1062"></a> -<span class="sourceLineNo">1063</span><a name="line.1063"></a> -<span class="sourceLineNo">1064</span> // Stop the snapshot and other procedure handlers, forcefully killing all running tasks<a name="line.1064"></a> -<span class="sourceLineNo">1065</span> if (rspmHost != null) {<a name="line.1065"></a> -<span class="sourceLineNo">1066</span> rspmHost.stop(this.abortRequested || this.killed);<a name="line.1066"></a> -<span class="sourceLineNo">1067</span> }<a name="line.1067"></a> -<span class="sourceLineNo">1068</span><a name="line.1068"></a> -<span class="sourceLineNo">1069</span> if (this.killed) {<a name="line.1069"></a> -<span class="sourceLineNo">1070</span> // Just skip out w/o closing regions. Used when testing.<a name="line.1070"></a> -<span class="sourceLineNo">1071</span> } else if (abortRequested) {<a name="line.1071"></a> -<span class="sourceLineNo">1072</span> if (this.fsOk) {<a name="line.1072"></a> -<span class="sourceLineNo">1073</span> closeUserRegions(abortRequested); // Don't leave any open file handles<a name="line.1073"></a> -<span class="sourceLineNo">1074</span> }<a name="line.1074"></a> -<span class="sourceLineNo">1075</span> LOG.info("aborting server " + this.serverName);<a name="line.1075"></a> -<span class="sourceLineNo">1076</span> } else {<a name="line.1076"></a> -<span class="sourceLineNo">1077</span> closeUserRegions(abortRequested);<a name="line.1077"></a> -<span class="sourceLineNo">1078</span> LOG.info("stopping server " + this.serverName);<a name="line.1078"></a> -<span class="sourceLineNo">1079</span> }<a name="line.1079"></a> -<span class="sourceLineNo">1080</span><a name="line.1080"></a> -<span class="sourceLineNo">1081</span> // so callers waiting for meta without timeout can stop<a name="line.1081"></a> -<span class="sourceLineNo">1082</span> if (this.metaTableLocator != null) this.metaTableLocator.stop();<a name="line.1082"></a> -<span class="sourceLineNo">1083</span> if (this.clusterConnection != null && !clusterConnection.isClosed()) {<a name="line.1083"></a> -<span class="sourceLineNo">1084</span> try {<a name="line.1084"></a> -<span class="sourceLineNo">1085</span> this.clusterConnection.close();<a name="line.1085"></a> -<span class="sourceLineNo">1086</span> } catch (IOException e) {<a name="line.1086"></a> -<span class="sourceLineNo">1087</span> // Although the {@link Closeable} interface throws an {@link<a name="line.1087"></a> -<span class="sourceLineNo">1088</span> // IOException}, in reality, the implementation would never do that.<a name="line.1088"></a> -<span class="sourceLineNo">1089</span> LOG.warn("Attempt to close server's short circuit ClusterConnection failed.", e);<a name="line.1089"></a> -<span class="sourceLineNo">1090</span> }<a name="line.1090"></a> -<span class="sourceLineNo">1091</span> }<a name="line.1091"></a> -<span class="sourceLineNo">1092</span><a name="line.1092"></a> -<span class="sourceLineNo">1093</span> // Closing the compactSplit thread before closing meta regions<a name="line.1093"></a> -<span class="sourceLineNo">1094</span> if (!this.killed && containsMetaTableRegions()) {<a name="line.1094"></a> -<span class="sourceLineNo">1095</span> if (!abortRequested || this.fsOk) {<a name="line.1095"></a> -<span class="sourceLineNo">1096</span> if (this.compactSplitThread != null) {<a name="line.1096"></a> -<span class="sourceLineNo">1097</span> this.compactSplitThread.join();<a name="line.1097"></a> -<span class="sourceLineNo">1098</span> this.compactSplitThread = null;<a name="line.1098"></a> -<span class="sourceLineNo">1099</span> }<a name="line.1099"></a> -<span class="sourceLineNo">1100</span> closeMetaTableRegions(abortRequested);<a name="line.1100"></a> -<span class="sourceLineNo">1101</span> }<a name="line.1101"></a> -<span class="sourceLineNo">1102</span> }<a name="line.1102"></a> -<span class="sourceLineNo">1103</span><a name="line.1103"></a> -<span class="sourceLineNo">1104</span> if (!this.killed && this.fsOk) {<a name="line.1104"></a> -<span class="sourceLineNo">1105</span> waitOnAllRegionsToClose(abortRequested);<a name="line.1105"></a> -<span class="sourceLineNo">1106</span> LOG.info("stopping server " + this.serverName + "; all regions closed.");<a name="line.1106"></a> +<span class="sourceLineNo">1059</span><a name="line.1059"></a> +<span class="sourceLineNo">1060</span> if (this.killed) {<a name="line.1060"></a> +<span class="sourceLineNo">1061</span> // Just skip out w/o closing regions. Used when testing.<a name="line.1061"></a> +<span class="sourceLineNo">1062</span> } else if (abortRequested) {<a name="line.1062"></a> +<span class="sourceLineNo">1063</span> if (this.fsOk) {<a name="line.1063"></a> +<span class="sourceLineNo">1064</span> closeUserRegions(abortRequested); // Don't leave any open file handles<a name="line.1064"></a> +<span class="sourceLineNo">1065</span> }<a name="line.1065"></a> +<span class="sourceLineNo">1066</span> LOG.info("aborting server " + this.serverName);<a name="line.1066"></a> +<span class="sourceLineNo">1067</span> } else {<a name="line.1067"></a> +<span class="sourceLineNo">1068</span> closeUserRegions(abortRequested);<a name="line.1068"></a> +<span class="sourceLineNo">1069</span> LOG.info("stopping server " + this.serverName);<a name="line.1069"></a> +<span class="sourceLineNo">1070</span> }<a name="line.1070"></a> +<span class="sourceLineNo">1071</span><a name="line.1071"></a> +<span class="sourceLineNo">1072</span> // so callers waiting for meta without timeout can stop<a name="line.1072"></a> +<span class="sourceLineNo">1073</span> if (this.metaTableLocator != null) this.metaTableLocator.stop();<a name="line.1073"></a> +<span class="sourceLineNo">1074</span> if (this.clusterConnection != null && !clusterConnection.isClosed()) {<a name="line.1074"></a> +<span class="sourceLineNo">1075</span> try {<a name="line.1075"></a> +<span class="sourceLineNo">1076</span> this.clusterConnection.close();<a name="line.1076"></a> +<span class="sourceLineNo">1077</span> } catch (IOException e) {<a name="line.1077"></a> +<span class="sourceLineNo">1078</span> // Although the {@link Closeable} interface throws an {@link<a name="line.1078"></a> +<span class="sourceLineNo">1079</span> // IOException}, in reality, the implementation would never do that.<a name="line.1079"></a> +<span class="sourceLineNo">1080</span> LOG.warn("Attempt to close server's short circuit ClusterConnection failed.", e);<a name="line.1080"></a> +<span class="sourceLineNo">1081</span> }<a name="line.1081"></a> +<span class="sourceLineNo">1082</span> }<a name="line.1082"></a> +<span class="sourceLineNo">1083</span><a name="line.1083"></a> +<span class="sourceLineNo">1084</span> // Closing the compactSplit thread before closing meta regions<a name="line.1084"></a> +<span class="sourceLineNo">1085</span> if (!this.killed && containsMetaTableRegions()) {<a name="line.1085"></a> +<span class="sourceLineNo">1086</span> if (!abortRequested || this.fsOk) {<a name="line.1086"></a> +<span class="sourceLineNo">1087</span> if (this.compactSplitThread != null) {<a name="line.1087"></a> +<span class="sourceLineNo">1088</span> this.compactSplitThread.join();<a name="line.1088"></a> +<span class="sourceLineNo">1089</span> this.compactSplitThread = null;<a name="line.1089"></a> +<span class="sourceLineNo">1090</span> }<a name="line.1090"></a> +<span class="sourceLineNo">1091</span> closeMetaTableRegions(abortRequested);<a name="line.1091"></a> +<span class="sourceLineNo">1092</span> }<a name="line.1092"></a> +<span class="sourceLineNo">1093</span> }<a name="line.1093"></a> +<span class="sourceLineNo">1094</span><a name="line.1094"></a> +<span class="sourceLineNo">1095</span> if (!this.killed && this.fsOk) {<a name="line.1095"></a> +<span class="sourceLineNo">1096</span> waitOnAllRegionsToClose(abortRequested);<a name="line.1096"></a> +<span class="sourceLineNo">1097</span> LOG.info("stopping server " + this.serverName + "; all regions closed.");<a name="line.1097"></a> +<span class="sourceLineNo">1098</span> }<a name="line.1098"></a> +<span class="sourceLineNo">1099</span><a name="line.1099"></a> +<span class="sourceLineNo">1100</span> // Stop the quota manager<a name="line.1100"></a> +<span class="sourceLineNo">1101</span> if (rsQuotaManager != null) {<a name="line.1101"></a> +<span class="sourceLineNo">1102</span> rsQuotaManager.stop();<a name="line.1102"></a> +<span class="sourceLineNo">1103</span> }<a name="line.1103"></a> +<span class="sourceLineNo">1104</span> if (rsSpaceQuotaManager != null) {<a name="line.1104"></a> +<span class="sourceLineNo">1105</span> rsSpaceQuotaManager.stop();<a name="line.1105"></a> +<span class="sourceLineNo">1106</span> rsSpaceQuotaManager = null;<a name="line.1106"></a> <span class="sourceLineNo">1107</span> }<a name="line.1107"></a> <span class="sourceLineNo">1108</span><a name="line.1108"></a> <span class="sourceLineNo">1109</span> //fsOk flag may be changed when closing regions throws exception.<a name="line.1109"></a> @@ -3705,9 +3705,9 @@ <span class="sourceLineNo">3697</span><a name="line.3697"></a> <span class="sourceLineNo">3698</span> @Override<a name="line.3698"></a> <span class="sourceLineNo">3699</span> public boolean reportFileArchivalForQuotas(TableName tableName,<a name="line.3699"></a> -<span class="sourceLineNo">3700</span> Collection<Entry<String,Long>> archivedFiles) {<a name="line.3700"></a> +<span class="sourceLineNo">3700</span> Collection<Entry<String, Long>> archivedFiles) {<a name="line.3700"></a> <span class="sourceLineNo">3701</span> RegionServerStatusService.BlockingInterface rss = rssStub;<a name="line.3701"></a> -<span class="sourceLineNo">3702</span> if (rss == null) {<a name="line.3702"></a> +<span class="sourceLineNo">3702</span> if (rss == null || rsSpaceQuotaManager == null) {<a name="line.3702"></a> <span class="sourceLineNo">3703</span> // the current server could be stopping.<a name="line.3703"></a> <span class="sourceLineNo">3704</span> LOG.trace("Skipping file archival reporting to HMaster as stub is null");<a name="line.3704"></a> <span class="sourceLineNo">3705</span> return false;<a name="line.3705"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html index d2efdfe..9644187 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html @@ -1060,58 +1060,58 @@ <span class="sourceLineNo">1052</span> if (this.storefileRefresher != null) this.storefileRefresher.cancel(true);<a name="line.1052"></a> <span class="sourceLineNo">1053</span> sendShutdownInterrupt();<a name="line.1053"></a> <span class="sourceLineNo">1054</span><a name="line.1054"></a> -<span class="sourceLineNo">1055</span> // Stop the quota manager<a name="line.1055"></a> -<span class="sourceLineNo">1056</span> if (rsQuotaManager != null) {<a name="line.1056"></a> -<span class="sourceLineNo">1057</span> rsQuotaManager.stop();<a name="line.1057"></a> +<span class="sourceLineNo">1055</span> // Stop the snapshot and other procedure handlers, forcefully killing all running tasks<a name="line.1055"></a> +<span class="sourceLineNo">1056</span> if (rspmHost != null) {<a name="line.1056"></a> +<span class="sourceLineNo">1057</span> rspmHost.stop(this.abortRequested || this.killed);<a name="line.1057"></a> <span class="sourceLineNo">1058</span> }<a name="line.1058"></a> -<span class="sourceLineNo">1059</span> if (rsSpaceQuotaManager != null) {<a name="line.1059"></a> -<span class="sourceLineNo">1060</span> rsSpaceQuotaManager.stop();<a name="line.1060"></a> -<span class="sourceLineNo">1061</span> rsSpaceQuotaManager = null;<a name="line.1061"></a> -<span class="sourceLineNo">1062</span> }<a name="line.1062"></a> -<span class="sourceLineNo">1063</span><a name="line.1063"></a> -<span class="sourceLineNo">1064</span> // Stop the snapshot and other procedure handlers, forcefully killing all running tasks<a name="line.1064"></a> -<span class="sourceLineNo">1065</span> if (rspmHost != null) {<a name="line.1065"></a> -<span class="sourceLineNo">1066</span> rspmHost.stop(this.abortRequested || this.killed);<a name="line.1066"></a> -<span class="sourceLineNo">1067</span> }<a name="line.1067"></a> -<span class="sourceLineNo">1068</span><a name="line.1068"></a> -<span class="sourceLineNo">1069</span> if (this.killed) {<a name="line.1069"></a> -<span class="sourceLineNo">1070</span> // Just skip out w/o closing regions. Used when testing.<a name="line.1070"></a> -<span class="sourceLineNo">1071</span> } else if (abortRequested) {<a name="line.1071"></a> -<span class="sourceLineNo">1072</span> if (this.fsOk) {<a name="line.1072"></a> -<span class="sourceLineNo">1073</span> closeUserRegions(abortRequested); // Don't leave any open file handles<a name="line.1073"></a> -<span class="sourceLineNo">1074</span> }<a name="line.1074"></a> -<span class="sourceLineNo">1075</span> LOG.info("aborting server " + this.serverName);<a name="line.1075"></a> -<span class="sourceLineNo">1076</span> } else {<a name="line.1076"></a> -<span class="sourceLineNo">1077</span> closeUserRegions(abortRequested);<a name="line.1077"></a> -<span class="sourceLineNo">1078</span> LOG.info("stopping server " + this.serverName);<a name="line.1078"></a> -<span class="sourceLineNo">1079</span> }<a name="line.1079"></a> -<span class="sourceLineNo">1080</span><a name="line.1080"></a> -<span class="sourceLineNo">1081</span> // so callers waiting for meta without timeout can stop<a name="line.1081"></a> -<span class="sourceLineNo">1082</span> if (this.metaTableLocator != null) this.metaTableLocator.stop();<a name="line.1082"></a> -<span class="sourceLineNo">1083</span> if (this.clusterConnection != null && !clusterConnection.isClosed()) {<a name="line.1083"></a> -<span class="sourceLineNo">1084</span> try {<a name="line.1084"></a> -<span class="sourceLineNo">1085</span> this.clusterConnection.close();<a name="line.1085"></a> -<span class="sourceLineNo">1086</span> } catch (IOException e) {<a name="line.1086"></a> -<span class="sourceLineNo">1087</span> // Although the {@link Closeable} interface throws an {@link<a name="line.1087"></a> -<span class="sourceLineNo">1088</span> // IOException}, in reality, the implementation would never do that.<a name="line.1088"></a> -<span class="sourceLineNo">1089</span> LOG.warn("Attempt to close server's short circuit ClusterConnection failed.", e);<a name="line.1089"></a> -<span class="sourceLineNo">1090</span> }<a name="line.1090"></a> -<span class="sourceLineNo">1091</span> }<a name="line.1091"></a> -<span class="sourceLineNo">1092</span><a name="line.1092"></a> -<span class="sourceLineNo">1093</span> // Closing the compactSplit thread before closing meta regions<a name="line.1093"></a> -<span class="sourceLineNo">1094</span> if (!this.killed && containsMetaTableRegions()) {<a name="line.1094"></a> -<span class="sourceLineNo">1095</span> if (!abortRequested || this.fsOk) {<a name="line.1095"></a> -<span class="sourceLineNo">1096</span> if (this.compactSplitThread != null) {<a name="line.1096"></a> -<span class="sourceLineNo">1097</span> this.compactSplitThread.join();<a name="line.1097"></a> -<span class="sourceLineNo">1098</span> this.compactSplitThread = null;<a name="line.1098"></a> -<span class="sourceLineNo">1099</span> }<a name="line.1099"></a> -<span class="sourceLineNo">1100</span> closeMetaTableRegions(abortRequested);<a name="line.1100"></a> -<span class="sourceLineNo">1101</span> }<a name="line.1101"></a> -<span class="sourceLineNo">1102</span> }<a name="line.1102"></a> -<span class="sourceLineNo">1103</span><a name="line.1103"></a> -<span class="sourceLineNo">1104</span> if (!this.killed && this.fsOk) {<a name="line.1104"></a> -<span class="sourceLineNo">1105</span> waitOnAllRegionsToClose(abortRequested);<a name="line.1105"></a> -<span class="sourceLineNo">1106</span> LOG.info("stopping server " + this.serverName + "; all regions closed.");<a name="line.1106"></a> +<span class="sourceLineNo">1059</span><a name="line.1059"></a> +<span class="sourceLineNo">1060</span> if (this.killed) {<a name="line.1060"></a> +<span class="sourceLineNo">1061</span> // Just skip out w/o closing regions. Used when testing.<a name="line.1061"></a> +<span class="sourceLineNo">1062</span> } else if (abortRequested) {<a name="line.1062"></a> +<span class="sourceLineNo">1063</span> if (this.fsOk) {<a name="line.1063"></a> +<span class="sourceLineNo">1064</span> closeUserRegions(abortRequested); // Don't leave any open file handles<a name="line.1064"></a> +<span class="sourceLineNo">1065</span> }<a name="line.1065"></a> +<span class="sourceLineNo">1066</span> LOG.info("aborting server " + this.serverName);<a name="line.1066"></a> +<span class="sourceLineNo">1067</span> } else {<a name="line.1067"></a> +<span class="sourceLineNo">1068</span> closeUserRegions(abortRequested);<a name="line.1068"></a> +<span class="sourceLineNo">1069</span> LOG.info("stopping server " + this.serverName);<a name="line.1069"></a> +<span class="sourceLineNo">1070</span> }<a name="line.1070"></a> +<span class="sourceLineNo">1071</span><a name="line.1071"></a> +<span class="sourceLineNo">1072</span> // so callers waiting for meta without timeout can stop<a name="line.1072"></a> +<span class="sourceLineNo">1073</span> if (this.metaTableLocator != null) this.metaTableLocator.stop();<a name="line.1073"></a> +<span class="sourceLineNo">1074</span> if (this.clusterConnection != null && !clusterConnection.isClosed()) {<a name="line.1074"></a> +<span class="sourceLineNo">1075</span> try {<a name="line.1075"></a> +<span class="sourceLineNo">1076</span> this.clusterConnection.close();<a name="line.1076"></a> +<span class="sourceLineNo">1077</span> } catch (IOException e) {<a name="line.1077"></a> +<span class="sourceLineNo">1078</span> // Although the {@link Closeable} interface throws an {@link<a name="line.1078"></a> +<span class="sourceLineNo">1079</span> // IOException}, in reality, the implementation would never do that.<a name="line.1079"></a> +<span class="sourceLineNo">1080</span> LOG.warn("Attempt to close server's short circuit ClusterConnection failed.", e);<a name="line.1080"></a> +<span class="sourceLineNo">1081</span> }<a name="line.1081"></a> +<span class="sourceLineNo">1082</span> }<a name="line.1082"></a> +<span class="sourceLineNo">1083</span><a name="line.1083"></a> +<span class="sourceLineNo">1084</span> // Closing the compactSplit thread before closing meta regions<a name="line.1084"></a> +<span class="sourceLineNo">1085</span> if (!this.killed && containsMetaTableRegions()) {<a name="line.1085"></a> +<span class="sourceLineNo">1086</span> if (!abortRequested || this.fsOk) {<a name="line.1086"></a> +<span class="sourceLineNo">1087</span> if (this.compactSplitThread != null) {<a name="line.1087"></a> +<span class="sourceLineNo">1088</span> this.compactSplitThread.join();<a name="line.1088"></a> +<span class="sourceLineNo">1089</span> this.compactSplitThread = null;<a name="line.1089"></a> +<span class="sourceLineNo">1090</span> }<a name="line.1090"></a> +<span class="sourceLineNo">1091</span> closeMetaTableRegions(abortRequested);<a name="line.1091"></a> +<span class="sourceLineNo">1092</span> }<a name="line.1092"></a> +<span class="sourceLineNo">1093</span> }<a name="line.1093"></a> +<span class="sourceLineNo">1094</span><a name="line.1094"></a> +<span class="sourceLineNo">1095</span> if (!this.killed && this.fsOk) {<a name="line.1095"></a> +<span class="sourceLineNo">1096</span> waitOnAllRegionsToClose(abortRequested);<a name="line.1096"></a> +<span class="sourceLineNo">1097</span> LOG.info("stopping server " + this.serverName + "; all regions closed.");<a name="line.1097"></a> +<span class="sourceLineNo">1098</span> }<a name="line.1098"></a> +<span class="sourceLineNo">1099</span><a name="line.1099"></a> +<span class="sourceLineNo">1100</span> // Stop the quota manager<a name="line.1100"></a> +<span class="sourceLineNo">1101</span> if (rsQuotaManager != null) {<a name="line.1101"></a> +<span class="sourceLineNo">1102</span> rsQuotaManager.stop();<a name="line.1102"></a> +<span class="sourceLineNo">1103</span> }<a name="line.1103"></a> +<span class="sourceLineNo">1104</span> if (rsSpaceQuotaManager != null) {<a name="line.1104"></a> +<span class="sourceLineNo">1105</span> rsSpaceQuotaManager.stop();<a name="line.1105"></a> +<span class="sourceLineNo">1106</span> rsSpaceQuotaManager = null;<a name="line.1106"></a> <span class="sourceLineNo">1107</span> }<a name="line.1107"></a> <span class="sourceLineNo">1108</span><a name="line.1108"></a> <span class="sourceLineNo">1109</span> //fsOk flag may be changed when closing regions throws exception.<a name="line.1109"></a> @@ -3705,9 +3705,9 @@ <span class="sourceLineNo">3697</span><a name="line.3697"></a> <span class="sourceLineNo">3698</span> @Override<a name="line.3698"></a> <span class="sourceLineNo">3699</span> public boolean reportFileArchivalForQuotas(TableName tableName,<a name="line.3699"></a> -<span class="sourceLineNo">3700</span> Collection<Entry<String,Long>> archivedFiles) {<a name="line.3700"></a> +<span class="sourceLineNo">3700</span> Collection<Entry<String, Long>> archivedFiles) {<a name="line.3700"></a> <span class="sourceLineNo">3701</span> RegionServerStatusService.BlockingInterface rss = rssStub;<a name="line.3701"></a> -<span class="sourceLineNo">3702</span> if (rss == null) {<a name="line.3702"></a> +<span class="sourceLineNo">3702</span> if (rss == null || rsSpaceQuotaManager == null) {<a name="line.3702"></a> <span class="sourceLineNo">3703</span> // the current server could be stopping.<a name="line.3703"></a> <span class="sourceLineNo">3704</span> LOG.trace("Skipping file archival reporting to HMaster as stub is null");<a name="line.3704"></a> <span class="sourceLineNo">3705</span> return false;<a name="line.3705"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html index d2efdfe..9644187 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html @@ -1060,58 +1060,58 @@ <span class="sourceLineNo">1052</span> if (this.storefileRefresher != null) this.storefileRefresher.cancel(true);<a name="line.1052"></a> <span class="sourceLineNo">1053</span> sendShutdownInterrupt();<a name="line.1053"></a> <span class="sourceLineNo">1054</span><a name="line.1054"></a> -<span class="sourceLineNo">1055</span> // Stop the quota manager<a name="line.1055"></a> -<span class="sourceLineNo">1056</span> if (rsQuotaManager != null) {<a name="line.1056"></a> -<span class="sourceLineNo">1057</span> rsQuotaManager.stop();<a name="line.1057"></a> +<span class="sourceLineNo">1055</span> // Stop the snapshot and other procedure handlers, forcefully killing all running tasks<a name="line.1055"></a> +<span class="sourceLineNo">1056</span> if (rspmHost != null) {<a name="line.1056"></a> +<span class="sourceLineNo">1057</span> rspmHost.stop(this.abortRequested || this.killed);<a name="line.1057"></a> <span class="sourceLineNo">1058</span> }<a name="line.1058"></a> -<span class="sourceLineNo">1059</span> if (rsSpaceQuotaManager != null) {<a name="line.1059"></a> -<span class="sourceLineNo">1060</span> rsSpaceQuotaManager.stop();<a name="line.1060"></a> -<span class="sourceLineNo">1061</span> rsSpaceQuotaManager = null;<a name="line.1061"></a> -<span class="sourceLineNo">1062</span> }<a name="line.1062"></a> -<span class="sourceLineNo">1063</span><a name="line.1063"></a> -<span class="sourceLineNo">1064</span> // Stop the snapshot and other procedure handlers, forcefully killing all running tasks<a name="line.1064"></a> -<span class="sourceLineNo">1065</span> if (rspmHost != null) {<a name="line.1065"></a> -<span class="sourceLineNo">1066</span> rspmHost.stop(this.abortRequested || this.killed);<a name="line.1066"></a> -<span class="sourceLineNo">1067</span> }<a name="line.1067"></a> -<span class="sourceLineNo">1068</span><a name="line.1068"></a> -<span class="sourceLineNo">1069</span> if (this.killed) {<a name="line.1069"></a> -<span class="sourceLineNo">1070</span> // Just skip out w/o closing regions. Used when testing.<a name="line.1070"></a> -<span class="sourceLineNo">1071</span> } else if (abortRequested) {<a name="line.1071"></a> -<span class="sourceLineNo">1072</span> if (this.fsOk) {<a name="line.1072"></a> -<span class="sourceLineNo">1073</span> closeUserRegions(abortRequested); // Don't leave any open file handles<a name="line.1073"></a> -<span class="sourceLineNo">1074</span> }<a name="line.1074"></a> -<span class="sourceLineNo">1075</span> LOG.info("aborting server " + this.serverName);<a name="line.1075"></a> -<span class="sourceLineNo">1076</span> } else {<a name="line.1076"></a> -<span class="sourceLineNo">1077</span> closeUserRegions(abortRequested);<a name="line.1077"></a> -<span class="sourceLineNo">1078</span> LOG.info("stopping server " + this.serverName);<a name="line.1078"></a> -<span class="sourceLineNo">1079</span> }<a name="line.1079"></a> -<span class="sourceLineNo">1080</span><a name="line.1080"></a> -<span class="sourceLineNo">1081</span> // so callers waiting for meta without timeout can stop<a name="line.1081"></a> -<span class="sourceLineNo">1082</span> if (this.metaTableLocator != null) this.metaTableLocator.stop();<a name="line.1082"></a> -<span class="sourceLineNo">1083</span> if (this.clusterConnection != null && !clusterConnection.isClosed()) {<a name="line.1083"></a> -<span class="sourceLineNo">1084</span> try {<a name="line.1084"></a> -<span class="sourceLineNo">1085</span> this.clusterConnection.close();<a name="line.1085"></a> -<span class="sourceLineNo">1086</span> } catch (IOException e) {<a name="line.1086"></a> -<span class="sourceLineNo">1087</span> // Although the {@link Closeable} interface throws an {@link<a name="line.1087"></a> -<span class="sourceLineNo">1088</span> // IOException}, in reality, the implementation would never do that.<a name="line.1088"></a> -<span class="sourceLineNo">1089</span> LOG.warn("Attempt to close server's short circuit ClusterConnection failed.", e);<a name="line.1089"></a> -<span class="sourceLineNo">1090</span> }<a name="line.1090"></a> -<span class="sourceLineNo">1091</span> }<a name="line.1091"></a> -<span class="sourceLineNo">1092</span><a name="line.1092"></a> -<span class="sourceLineNo">1093</span> // Closing the compactSplit thread before closing meta regions<a name="line.1093"></a> -<span class="sourceLineNo">1094</span> if (!this.killed && containsMetaTableRegions()) {<a name="line.1094"></a> -<span class="sourceLineNo">1095</span> if (!abortRequested || this.fsOk) {<a name="line.1095"></a> -<span class="sourceLineNo">1096</span> if (this.compactSplitThread != null) {<a name="line.1096"></a> -<span class="sourceLineNo">1097</span> this.compactSplitThread.join();<a name="line.1097"></a> -<span class="sourceLineNo">1098</span> this.compactSplitThread = null;<a name="line.1098"></a> -<span class="sourceLineNo">1099</span> }<a name="line.1099"></a> -<span class="sourceLineNo">1100</span> closeMetaTableRegions(abortRequested);<a name="line.1100"></a> -<span class="sourceLineNo">1101</span> }<a name="line.1101"></a> -<span class="sourceLineNo">1102</span> }<a name="line.1102"></a> -<span class="sourceLineNo">1103</span><a name="line.1103"></a> -<span class="sourceLineNo">1104</span> if (!this.killed && this.fsOk) {<a name="line.1104"></a> -<span class="sourceLineNo">1105</span> waitOnAllRegionsToClose(abortRequested);<a name="line.1105"></a> -<span class="sourceLineNo">1106</span> LOG.info("stopping server " + this.serverName + "; all regions closed.");<a name="line.1106"></a> +<span class="sourceLineNo">1059</span><a name="line.1059"></a> +<span class="sourceLineNo">1060</span> if (this.killed) {<a name="line.1060"></a> +<span class="sourceLineNo">1061</span> // Just skip out w/o closing regions. Used when testing.<a name="line.1061"></a> +<span class="sourceLineNo">1062</span> } else if (abortRequested) {<a name="line.1062"></a> +<span class="sourceLineNo">1063</span> if (this.fsOk) {<a name="line.1063"></a> +<span class="sourceLineNo">1064</span> closeUserRegions(abortRequested); // Don't leave any open file handles<a name="line.1064"></a> +<span class="sourceLineNo">1065</span> }<a name="line.1065"></a> +<span class="sourceLineNo">1066</span> LOG.info("aborting server " + this.serverName);<a name="line.1066"></a> +<span class="sourceLineNo">1067</span> } else {<a name="line.1067"></a> +<span class="sourceLineNo">1068</span> closeUserRegions(abortRequested);<a name="line.1068"></a> +<span class="sourceLineNo">1069</span> LOG.info("stopping server " + this.serverName);<a name="line.1069"></a> +<span class="sourceLineNo">1070</span> }<a name="line.1070"></a> +<span class="sourceLineNo">1071</span><a name="line.1071"></a> +<span class="sourceLineNo">1072</span> // so callers waiting for meta without timeout can stop<a name="line.1072"></a> +<span class="sourceLineNo">1073</span> if (this.metaTableLocator != null) this.metaTableLocator.stop();<a name="line.1073"></a> +<span class="sourceLineNo">1074</span> if (this.clusterConnection != null && !clusterConnection.isClosed()) {<a name="line.1074"></a> +<span class="sourceLineNo">1075</span> try {<a name="line.1075"></a> +<span class="sourceLineNo">1076</span> this.clusterConnection.close();<a name="line.1076"></a> +<span class="sourceLineNo">1077</span> } catch (IOException e) {<a name="line.1077"></a> +<span class="sourceLineNo">1078</span> // Although the {@link Closeable} interface throws an {@link<a name="line.1078"></a> +<span class="sourceLineNo">1079</span> // IOException}, in reality, the implementation would never do that.<a name="line.1079"></a> +<span class="sourceLineNo">1080</span> LOG.warn("Attempt to close server's short circuit ClusterConnection failed.", e);<a name="line.1080"></a> +<span class="sourceLineNo">1081</span> }<a name="line.1081"></a> +<span class="sourceLineNo">1082</span> }<a name="line.1082"></a> +<span class="sourceLineNo">1083</span><a name="line.1083"></a> +<span class="sourceLineNo">1084</span> // Closing the compactSplit thread before closing meta regions<a name="line.1084"></a> +<span class="sourceLineNo">1085</span> if (!this.killed && containsMetaTableRegions()) {<a name="line.1085"></a> +<span class="sourceLineNo">1086</span> if (!abortRequested || this.fsOk) {<a name="line.1086"></a> +<span class="sourceLineNo">1087</span> if (this.compactSplitThread != null) {<a name="line.1087"></a> +<span class="sourceLineNo">1088</span> this.compactSplitThread.join();<a name="line.1088"></a> +<span class="sourceLineNo">1089</span> this.compactSplitThread = null;<a name="line.1089"></a> +<span class="sourceLineNo">1090</span> }<a name="line.1090"></a> +<span class="sourceLineNo">1091</span> closeMetaTableRegions(abortRequested);<a name="line.1091"></a> +<span class="sourceLineNo">1092</span> }<a name="line.1092"></a> +<span class="sourceLineNo">1093</span> }<a name="line.1093"></a> +<span class="sourceLineNo">1094</span><a name="line.1094"></a> +<span class="sourceLineNo">1095</span> if (!this.killed && this.fsOk) {<a name="line.1095"></a> +<span class="sourceLineNo">1096</span> waitOnAllRegionsToClose(abortRequested);<a name="line.1096"></a> +<span class="sourceLineNo">1097</span> LOG.info("stopping server " + this.serverName + "; all regions closed.");<a name="line.1097"></a> +<span class="sourceLineNo">1098</span> }<a name="line.1098"></a> +<span class="sourceLineNo">1099</span><a name="line.1099"></a> +<span class="sourceLineNo">1100</span> // Stop the quota manager<a name="line.1100"></a> +<span class="sourceLineNo">1101</span> if (rsQuotaManager != null) {<a name="line.1101"></a> +<span class="sourceLineNo">1102</span> rsQuotaManager.stop();<a name="line.1102"></a> +<span class="sourceLineNo">1103</span> }<a name="line.1103"></a> +<span class="sourceLineNo">1104</span> if (rsSpaceQuotaManager != null) {<a name="line.1104"></a> +<span class="sourceLineNo">1105</span> rsSpaceQuotaManager.stop();<a name="line.1105"></a> +<span class="sourceLineNo">1106</span> rsSpaceQuotaManager = null;<a name="line.1106"></a> <span class="sourceLineNo">1107</span> }<a name="line.1107"></a> <span class="sourceLineNo">1108</span><a name="line.1108"></a> <span class="sourceLineNo">1109</span> //fsOk flag may be changed when closing regions throws exception.<a name="line.1109"></a> @@ -3705,9 +3705,9 @@ <span class="sourceLineNo">3697</span><a name="line.3697"></a> <span class="sourceLineNo">3698</span> @Override<a name="line.3698"></a> <span class="sourceLineNo">3699</span> public boolean reportFileArchivalForQuotas(TableName tableName,<a name="line.3699"></a> -<span class="sourceLineNo">3700</span> Collection<Entry<String,Long>> archivedFiles) {<a name="line.3700"></a> +<span class="sourceLineNo">3700</span> Collection<Entry<String, Long>> archivedFiles) {<a name="line.3700"></a> <span class="sourceLineNo">3701</span> RegionServerStatusService.BlockingInterface rss = rssStub;<a name="line.3701"></a> -<span class="sourceLineNo">3702</span> if (rss == null) {<a name="line.3702"></a> +<span class="sourceLineNo">3702</span> if (rss == null || rsSpaceQuotaManager == null) {<a name="line.3702"></a> <span class="sourceLineNo">3703</span> // the current server could be stopping.<a name="line.3703"></a> <span class="sourceLineNo">3704</span> LOG.trace("Skipping file archival reporting to HMaster as stub is null");<a name="line.3704"></a> <span class="sourceLineNo">3705</span> return false;<a name="line.3705"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.PeriodicMemStoreFlusher.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.PeriodicMemStoreFlusher.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.PeriodicMemStoreFlusher.html index d2efdfe..9644187 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.PeriodicMemStoreFlusher.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.PeriodicMemStoreFlusher.html @@ -1060,58 +1060,58 @@ <span class="sourceLineNo">1052</span> if (this.storefileRefresher != null) this.storefileRefresher.cancel(true);<a name="line.1052"></a> <span class="sourceLineNo">1053</span> sendShutdownInterrupt();<a name="line.1053"></a> <span class="sourceLineNo">1054</span><a name="line.1054"></a> -<span class="sourceLineNo">1055</span> // Stop the quota manager<a name="line.1055"></a> -<span class="sourceLineNo">1056</span> if (rsQuotaManager != null) {<a name="line.1056"></a> -<span class="sourceLineNo">1057</span> rsQuotaManager.stop();<a name="line.1057"></a> +<span class="sourceLineNo">1055</span> // Stop the snapshot and other procedure handlers, forcefully killing all running tasks<a name="line.1055"></a> +<span class="sourceLineNo">1056</span> if (rspmHost != null) {<a name="line.1056"></a> +<span class="sourceLineNo">1057</span> rspmHost.stop(this.abortRequested || this.killed);<a name="line.1057"></a> <span class="sourceLineNo">1058</span> }<a name="line.1058"></a> -<span class="sourceLineNo">1059</span> if (rsSpaceQuotaManager != null) {<a name="line.1059"></a> -<span class="sourceLineNo">1060</span> rsSpaceQuotaManager.stop();<a name="line.1060"></a> -<span class="sourceLineNo">1061</span> rsSpaceQuotaManager = null;<a name="line.1061"></a> -<span class="sourceLineNo">1062</span> }<a name="line.1062"></a> -<span class="sourceLineNo">1063</span><a name="line.1063"></a> -<span class="sourceLineNo">1064</span> // Stop the snapshot and other procedure handlers, forcefully killing all running tasks<a name="line.1064"></a> -<span class="sourceLineNo">1065</span> if (rspmHost != null) {<a name="line.1065"></a> -<span class="sourceLineNo">1066</span> rspmHost.stop(this.abortRequested || this.killed);<a name="line.1066"></a> -<span class="sourceLineNo">1067</span> }<a name="line.1067"></a> -<span class="sourceLineNo">1068</span><a name="line.1068"></a> -<span class="sourceLineNo">1069</span> if (this.killed) {<a name="line.1069"></a> -<span class="sourceLineNo">1070</span> // Just skip out w/o closing regions. Used when testing.<a name="line.1070"></a> -<span class="sourceLineNo">1071</span> } else if (abortRequested) {<a name="line.1071"></a> -<span class="sourceLineNo">1072</span> if (this.fsOk) {<a name="line.1072"></a> -<span class="sourceLineNo">1073</span> closeUserRegions(abortRequested); // Don't leave any open file handles<a name="line.1073"></a> -<span class="sourceLineNo">1074</span> }<a name="line.1074"></a> -<span class="sourceLineNo">1075</span> LOG.info("aborting server " + this.serverName);<a name="line.1075"></a> -<span class="sourceLineNo">1076</span> } else {<a name="line.1076"></a> -<span class="sourceLineNo">1077</span> closeUserRegions(abortRequested);<a name="line.1077"></a> -<span class="sourceLineNo">1078</span> LOG.info("stopping server " + this.serverName);<a name="line.1078"></a> -<span class="sourceLineNo">1079</span> }<a name="line.1079"></a> -<span class="sourceLineNo">1080</span><a name="line.1080"></a> -<span class="sourceLineNo">1081</span> // so callers waiting for meta without timeout can stop<a name="line.1081"></a> -<span class="sourceLineNo">1082</span> if (this.metaTableLocator != null) this.metaTableLocator.stop();<a name="line.1082"></a> -<span class="sourceLineNo">1083</span> if (this.clusterConnection != null && !clusterConnection.isClosed()) {<a name="line.1083"></a> -<span class="sourceLineNo">1084</span> try {<a name="line.1084"></a> -<span class="sourceLineNo">1085</span> this.clusterConnection.close();<a name="line.1085"></a> -<span class="sourceLineNo">1086</span> } catch (IOException e) {<a name="line.1086"></a> -<span class="sourceLineNo">1087</span> // Although the {@link Closeable} interface throws an {@link<a name="line.1087"></a> -<span class="sourceLineNo">1088</span> // IOException}, in reality, the implementation would never do that.<a name="line.1088"></a> -<span class="sourceLineNo">1089</span> LOG.warn("Attempt to close server's short circuit ClusterConnection failed.", e);<a name="line.1089"></a> -<span class="sourceLineNo">1090</span> }<a name="line.1090"></a> -<span class="sourceLineNo">1091</span> }<a name="line.1091"></a> -<span class="sourceLineNo">1092</span><a name="line.1092"></a> -<span class="sourceLineNo">1093</span> // Closing the compactSplit thread before closing meta regions<a name="line.1093"></a> -<span class="sourceLineNo">1094</span> if (!this.killed && containsMetaTableRegions()) {<a name="line.1094"></a> -<span class="sourceLineNo">1095</span> if (!abortRequested || this.fsOk) {<a name="line.1095"></a> -<span class="sourceLineNo">1096</span> if (this.compactSplitThread != null) {<a name="line.1096"></a> -<span class="sourceLineNo">1097</span> this.compactSplitThread.join();<a name="line.1097"></a> -<span class="sourceLineNo">1098</span> this.compactSplitThread = null;<a name="line.1098"></a> -<span class="sourceLineNo">1099</span> }<a name="line.1099"></a> -<span class="sourceLineNo">1100</span> closeMetaTableRegions(abortRequested);<a name="line.1100"></a> -<span class="sourceLineNo">1101</span> }<a name="line.1101"></a> -<span class="sourceLineNo">1102</span> }<a name="line.1102"></a> -<span class="sourceLineNo">1103</span><a name="line.1103"></a> -<span class="sourceLineNo">1104</span> if (!this.killed && this.fsOk) {<a name="line.1104"></a> -<span class="sourceLineNo">1105</span> waitOnAllRegionsToClose(abortRequested);<a name="line.1105"></a> -<span class="sourceLineNo">1106</span> LOG.info("stopping server " + this.serverName + "; all regions closed.");<a name="line.1106"></a> +<span class="sourceLineNo">1059</span><a name="line.1059"></a> +<span class="sourceLineNo">1060</span> if (this.killed) {<a name="line.1060"></a> +<span class="sourceLineNo">1061</span> // Just skip out w/o closing regions. Used when testing.<a name="line.1061"></a> +<span class="sourceLineNo">1062</span> } else if (abortRequested) {<a name="line.1062"></a> +<span class="sourceLineNo">1063</span> if (this.fsOk) {<a name="line.1063"></a> +<span class="sourceLineNo">1064</span> closeUserRegions(abortRequested); // Don't leave any open file handles<a name="line.1064"></a> +<span class="sourceLineNo">1065</span> }<a name="line.1065"></a> +<span class="sourceLineNo">1066</span> LOG.info("aborting server " + this.serverName);<a name="line.1066"></a> +<span class="sourceLineNo">1067</span> } else {<a name="line.1067"></a> +<span class="sourceLineNo">1068</span> closeUserRegions(abortRequested);<a name="line.1068"></a> +<span class="sourceLineNo">1069</span> LOG.info("stopping server " + this.serverName);<a name="line.1069"></a> +<span class="sourceLineNo">1070</span> }<a name="line.1070"></a> +<span class="sourceLineNo">1071</span><a name="line.1071"></a> +<span class="sourceLineNo">1072</span> // so callers waiting for meta without timeout can stop<a name="line.1072"></a> +<span class="sourceLineNo">1073</span> if (this.metaTableLocator != null) this.metaTableLocator.stop();<a name="line.1073"></a> +<span class="sourceLineNo">1074</span> if (this.clusterConnection != null && !clusterConnection.isClosed()) {<a name="line.1074"></a> +<span class="sourceLineNo">1075</span> try {<a name="line.1075"></a> +<span class="sourceLineNo">1076</span> this.clusterConnection.close();<a name="line.1076"></a> +<span class="sourceLineNo">1077</span> } catch (IOException e) {<a name="line.1077"></a> +<span class="sourceLineNo">1078</span> // Although the {@link Closeable} interface throws an {@link<a name="line.1078"></a> +<span class="sourceLineNo">1079</span> // IOException}, in reality, the implementation would never do that.<a name="line.1079"></a> +<span class="sourceLineNo">1080</span> LOG.warn("Attempt to close server's short circuit ClusterConnection failed.", e);<a name="line.1080"></a> +<span class="sourceLineNo">1081</span> }<a name="line.1081"></a> +<span class="sourceLineNo">1082</span> }<a name="line.1082"></a> +<span class="sourceLineNo">1083</span><a name="line.1083"></a> +<span class="sourceLineNo">1084</span> // Closing the compactSplit thread before closing meta regions<a name="line.1084"></a> +<span class="sourceLineNo">1085</span> if (!this.killed && containsMetaTableRegions()) {<a name="line.1085"></a> +<span class="sourceLineNo">1086</span> if (!abortRequested || this.fsOk) {<a name="line.1086"></a> +<span class="sourceLineNo">1087</span> if (this.compactSplitThread != null) {<a name="line.1087"></a> +<span class="sourceLineNo">1088</span> this.compactSplitThread.join();<a name="line.1088"></a> +<span class="sourceLineNo">1089</span> this.compactSplitThread = null;<a name="line.1089"></a> +<span class="sourceLineNo">1090</span> }<a name="line.1090"></a> +<span class="sourceLineNo">1091</span> closeMetaTableRegions(abortRequested);<a name="line.1091"></a> +<span class="sourceLineNo">1092</span> }<a name="line.1092"></a> +<span class="sourceLineNo">1093</span> }<a name="line.1093"></a> +<span class="sourceLineNo">1094</span><a name="line.1094"></a> +<span class="sourceLineNo">1095</span> if (!this.killed && this.fsOk) {<a name="line.1095"></a> +<span class="sourceLineNo">1096</span> waitOnAllRegionsToClose(abortRequested);<a name="line.1096"></a> +<span class="sourceLineNo">1097</span> LOG.info("stopping server " + this.serverName + "; all regions closed.");<a name="line.1097"></a> +<span class="sourceLineNo">1098</span> }<a name="line.1098"></a> +<span class="sourceLineNo">1099</span><a name="line.1099"></a> +<span class="sourceLineNo">1100</span> // Stop the quota manager<a name="line.1100"></a> +<span class="sourceLineNo">1101</span> if (rsQuotaManager != null) {<a name="line.1101"></a> +<span class="sourceLineNo">1102</span> rsQuotaManager.stop();<a name="line.1102"></a> +<span class="sourceLineNo">1103</span> }<a name="line.1103"></a> +<span class="sourceLineNo">1104</span> if (rsSpaceQuotaManager != null) {<a name="line.1104"></a> +<span class="sourceLineNo">1105</span> rsSpaceQuotaManager.stop();<a name="line.1105"></a> +<span class="sourceLineNo">1106</span> rsSpaceQuotaManager = null;<a name="line.1106"></a> <span class="sourceLineNo">1107</span> }<a name="line.1107"></a> <span class="sourceLineNo">1108</span><a name="line.1108"></a> <span class="sourceLineNo">1109</span> //fsOk flag may be changed when closing regions throws exception.<a name="line.1109"></a> @@ -3705,9 +3705,9 @@ <span class="sourceLineNo">3697</span><a name="line.3697"></a> <span class="sourceLineNo">3698</span> @Override<a name="line.3698"></a> <span class="sourceLineNo">3699</span> public boolean reportFileArchivalForQuotas(TableName tableName,<a name="line.3699"></a> -<span class="sourceLineNo">3700</span> Collection<Entry<String,Long>> archivedFiles) {<a name="line.3700"></a> +<span class="sourceLineNo">3700</span> Collection<Entry<String, Long>> archivedFiles) {<a name="line.3700"></a> <span class="sourceLineNo">3701</span> RegionServerStatusService.BlockingInterface rss = rssStub;<a name="line.3701"></a> -<span class="sourceLineNo">3702</span> if (rss == null) {<a name="line.3702"></a> +<span class="sourceLineNo">3702</span> if (rss == null || rsSpaceQuotaManager == null) {<a name="line.3702"></a> <span class="sourceLineNo">3703</span> // the current server could be stopping.<a name="line.3703"></a> <span class="sourceLineNo">3704</span> LOG.trace("Skipping file archival reporting to HMaster as stub is null");<a name="line.3704"></a> <span class="sourceLineNo">3705</span> return false;<a name="line.3705"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.html index d2efdfe..9644187 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/HRegionServer.html @@ -1060,58 +1060,58 @@ <span class="sourceLineNo">1052</span> if (this.storefileRefresher != null) this.storefileRefresher.cancel(true);<a name="line.1052"></a> <span class="sourceLineNo">1053</span> sendShutdownInterrupt();<a name="line.1053"></a> <span class="sourceLineNo">1054</span><a name="line.1054"></a> -<span class="sourceLineNo">1055</span> // Stop the quota manager<a name="line.1055"></a> -<span class="sourceLineNo">1056</span> if (rsQuotaManager != null) {<a name="line.1056"></a> -<span class="sourceLineNo">1057</span> rsQuotaManager.stop();<a name="line.1057"></a> +<span class="sourceLineNo">1055</span> // Stop the snapshot and other procedure handlers, forcefully killing all running tasks<a name="line.1055"></a> +<span class="sourceLineNo">1056</span> if (rspmHost != null) {<a name="line.1056"></a> +<span class="sourceLineNo">1057</span> rspmHost.stop(this.abortRequested || this.killed);<a name="line.1057"></a> <span class="sourceLineNo">1058</span> }<a name="line.1058"></a> -<span class="sourceLineNo">1059</span> if (rsSpaceQuotaManager != null) {<a name="line.1059"></a> -<span class="sourceLineNo">1060</span> rsSpaceQuotaManager.stop();<a name="line.1060"></a> -<span class="sourceLineNo">1061</span> rsSpaceQuotaManager = null;<a name="line.1061"></a> -<span class="sourceLineNo">1062</span> }<a name="line.1062"></a> -<span class="sourceLineNo">1063</span><a name="line.1063"></a> -<span class="sourceLineNo">1064</span> // Stop the snapshot and other procedure handlers, forcefully killing all running tasks<a name="line.1064"></a> -<span class="sourceLineNo">1065</span> if (rspmHost != null) {<a name="line.1065"></a> -<span class="sourceLineNo">1066</span> rspmHost.stop(this.abortRequested || this.killed);<a name="line.1066"></a> -<span class="sourceLineNo">1067</span> }<a name="line.1067"></a> -<span class="sourceLineNo">1068</span><a name="line.1068"></a> -<span class="sourceLineNo">1069</span> if (this.killed) {<a name="line.1069"></a> -<span class="sourceLineNo">1070</span> // Just skip out w/o closing regions. Used when testing.<a name="line.1070"></a> -<span class="sourceLineNo">1071</span> } else if (abortRequested) {<a name="line.1071"></a> -<span class="sourceLineNo">1072</span> if (this.fsOk) {<a name="line.1072"></a> -<span class="sourceLineNo">1073</span> closeUserRegions(abortRequested); // Don't leave any open file handles<a name="line.1073"></a> -<span class="sourceLineNo">1074</span> }<a name="line.1074"></a> -<span class="sourceLineNo">1075</span> LOG.info("aborting server " + this.serverName);<a name="line.1075"></a> -<span class="sourceLineNo">1076</span> } else {<a name="line.1076"></a> -<span class="sourceLineNo">1077</span> closeUserRegions(abortRequested);<a name="line.1077"></a> -<span class="sourceLineNo">1078</span> LOG.info("stopping server " + this.serverName);<a name="line.1078"></a> -<span class="sourceLineNo">1079</span> }<a name="line.1079"></a> -<span class="sourceLineNo">1080</span><a name="line.1080"></a> -<span class="sourceLineNo">1081</span> // so callers waiting for meta without timeout can stop<a name="line.1081"></a> -<span class="sourceLineNo">1082</span> if (this.metaTableLocator != null) this.metaTableLocator.stop();<a name="line.1082"></a> -<span class="sourceLineNo">1083</span> if (this.clusterConnection != null && !clusterConnection.isClosed()) {<a name="line.1083"></a> -<span class="sourceLineNo">1084</span> try {<a name="line.1084"></a> -<span class="sourceLineNo">1085</span> this.clusterConnection.close();<a name="line.1085"></a> -<span class="sourceLineNo">1086</span> } catch (IOException e) {<a name="line.1086"></a> -<span class="sourceLineNo">1087</span> // Although the {@link Closeable} interface throws an {@link<a name="line.1087"></a> -<span class="sourceLineNo">1088</span> // IOException}, in reality, the implementation would never do that.<a name="line.1088"></a> -<span class="sourceLineNo">1089</span> LOG.warn("Attempt to close server's short circuit ClusterConnection failed.", e);<a name="line.1089"></a> -<span class="sourceLineNo">1090</span> }<a name="line.1090"></a> -<span class="sourceLineNo">1091</span> }<a name="line.1091"></a> -<span class="sourceLineNo">1092</span><a name="line.1092"></a> -<span class="sourceLineNo">1093</span> // Closing the compactSplit thread before closing meta regions<a name="line.1093"></a> -<span class="sourceLineNo">1094</span> if (!this.killed && containsMetaTableRegions()) {<a name="line.1094"></a> -<span class="sourceLineNo">1095</span> if (!abortRequested || this.fsOk) {<a name="line.1095"></a> -<span class="sourceLineNo">1096</span> if (this.compactSplitThread != null) {<a name="line.1096"></a> -<span class="sourceLineNo">1097</span> this.compactSplitThread.join();<a name="line.1097"></a> -<span class="sourceLineNo">1098</span> this.compactSplitThread = null;<a name="line.1098"></a> -<span class="sourceLineNo">1099</span> }<a name="line.1099"></a> -<span class="sourceLineNo">1100</span> closeMetaTableRegions(abortRequested);<a name="line.1100"></a> -<span class="sourceLineNo">1101</span> }<a name="line.1101"></a> -<span class="sourceLineNo">1102</span> }<a name="line.1102"></a> -<span class="sourceLineNo">1103</span><a name="line.1103"></a> -<span class="sourceLineNo">1104</span> if (!this.killed && this.fsOk) {<a name="line.1104"></a> -<span class="sourceLineNo">1105</span> waitOnAllRegionsToClose(abortRequested);<a name="line.1105"></a> -<span class="sourceLineNo">1106</span> LOG.info("stopping server " + this.serverName + "; all regions closed.");<a name="line.1106"></a> +<span class="sourceLineNo">1059</span><a name="line.1059"></a> +<span class="sourceLineNo">1060</span> if (this.killed) {<a name="line.1060"></a> +<span class="sourceLineNo">1061</span> // Just skip out w/o closing regions. Used when testing.<a name="line.1061"></a> +<span class="sourceLineNo">1062</span> } else if (abortRequested) {<a name="line.1062"></a> +<span class="sourceLineNo">1063</span> if (this.fsOk) {<a name="line.1063"></a> +<span class="sourceLineNo">1064</span> closeUserRegions(abortRequested); // Don't leave any open file handles<a name="line.1064"></a> +<span class="sourceLineNo">1065</span> }<a name="line.1065"></a> +<span class="sourceLineNo">1066</span> LOG.info("aborting server " + this.serverName);<a name="line.1066"></a> +<span class="sourceLineNo">1067</span> } else {<a name="line.1067"></a> +<span class="sourceLineNo">1068</span> closeUserRegions(abortRequested);<a name="line.1068"></a> +<span class="sourceLineNo">1069</span> LOG.info("stopping server " + this.serverName);<a name="line.1069"></a> +<span class="sourceLineNo">1070</span> }<a name="line.1070"></a> +<span class="sourceLineNo">1071</span><a name="line.1071"></a> +<span class="sourceLineNo">1072</span> // so callers waiting for meta without timeout can stop<a name="line.1072"></a> +<span class="sourceLineNo">1073</span> if (this.metaTableLocator != null) this.metaTableLocator.stop();<a name="line.1073"></a> +<span class="sourceLineNo">1074</span> if (this.clusterConnection != null && !clusterConnection.isClosed()) {<a name="line.1074"></a> +<span class="sourceLineNo">1075</span> try {<a name="line.1075"></a> +<span class="sourceLineNo">1076</span> this.clusterConnection.close();<a name="line.1076"></a> +<span class="sourceLineNo">1077</span> } catch (IOException e) {<a name="line.1077"></a> +<span class="sourceLineNo">1078</span> // Although the {@link Closeable} interface throws an {@link<a name="line.1078"></a> +<span class="sourceLineNo">1079</span> // IOException}, in reality, the implementation would never do that.<a name="line.1079"></a> +<span class="sourceLineNo">1080</span> LOG.warn("Attempt to close server's short circuit ClusterConnection failed.", e);<a name="line.1080"></a> +<span class="sourceLineNo">1081</span> }<a name="line.1081"></a> +<span class="sourceLineNo">1082</span> }<a name="line.1082"></a> +<span class="sourceLineNo">1083</span><a name="line.1083"></a> +<span class="sourceLineNo">1084</span> // Closing the compactSplit thread before closing meta regions<a name="line.1084"></a> +<span class="sourceLineNo">1085</span> if (!this.killed && containsMetaTableRegions()) {<a name="line.1085"></a> +<span class="sourceLineNo">1086</span> if (!abortRequested || this.fsOk) {<a name="line.1086"></a> +<span class="sourceLineNo">1087</span> if (this.compactSplitThread != null) {<a name="line.1087"></a> +<span class="sourceLineNo">1088</span> this.compactSplitThread.join();<a name="line.1088"></a> +<span class="sourceLineNo">1089</span> this.compactSplitThread = null;<a name="line.1089"></a> +<span class="sourceLineNo">1090</span> }<a name="line.1090"></a> +<span class="sourceLineNo">1091</span> closeMetaTableRegions(abortRequested);<a name="line.1091"></a> +<span class="sourceLineNo">1092</span> }<a name="line.1092"></a> +<span class="sourceLineNo">1093</span> }<a name="line.1093"></a> +<span class="sourceLineNo">1094</span><a name="line.1094"></a> +<span class="sourceLineNo">1095</span> if (!this.killed && this.fsOk) {<a name="line.1095"></a> +<span class="sourceLineNo">1096</span> waitOnAllRegionsToClose(abortRequested);<a name="line.1096"></a> +<span class="sourceLineNo">1097</span> LOG.info("stopping server " + this.serverName + "; all regions closed.");<a name="line.1097"></a> +<span class="sourceLineNo">1098</span> }<a name="line.1098"></a> +<span class="sourceLineNo">1099</span><a name="line.1099"></a> +<span class="sourceLineNo">1100</span> // Stop the quota manager<a name="line.1100"></a> +<span class="sourceLineNo">1101</span> if (rsQuotaManager != null) {<a name="line.1101"></a> +<span class="sourceLineNo">1102</span> rsQuotaManager.stop();<a name="line.1102"></a> +<span class="sourceLineNo">1103</span> }<a name="line.1103"></a> +<span class="sourceLineNo">1104</span> if (rsSpaceQuotaManager != null) {<a name="line.1104"></a> +<span class="sourceLineNo">1105</span> rsSpaceQuotaManager.stop();<a name="line.1105"></a> +<span class="sourceLineNo">1106</span> rsSpaceQuotaManager = null;<a name="line.1106"></a> <span class="sourceLineNo">1107</span> }<a name="line.1107"></a> <span class="sourceLineNo">1108</span><a name="line.1108"></a> <span class="sourceLineNo">1109</span> //fsOk flag may be changed when closing regions throws exception.<a name="line.1109"></a> @@ -3705,9 +3705,9 @@ <span class="sourceLineNo">3697</span><a name="line.3697"></a> <span class="sourceLineNo">3698</span> @Override<a name="line.3698"></a> <span class="sourceLineNo">3699</span> public boolean reportFileArchivalForQuotas(TableName tableName,<a name="line.3699"></a> -<span class="sourceLineNo">3700</span> Collection<Entry<String,Long>> archivedFiles) {<a name="line.3700"></a> +<span class="sourceLineNo">3700</span> Collection<Entry<String, Long>> archivedFiles) {<a name="line.3700"></a> <span class="sourceLineNo">3701</span> RegionServerStatusService.BlockingInterface rss = rssStub;<a name="line.3701"></a> -<span class="sourceLineNo">3702</span> if (rss == null) {<a name="line.3702"></a> +<span class="sourceLineNo">3702</span> if (rss == null || rsSpaceQuotaManager == null) {<a name="line.3702"></a> <span class="sourceLineNo">3703</span> // the current server could be stopping.<a name="line.3703"></a> <span class="sourceLineNo">3704</span> LOG.trace("Skipping file archival reporting to HMaster as stub is null");<a name="line.3704"></a> <span class="sourceLineNo">3705</span> return false;<a name="line.3705"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/downloads.html ---------------------------------------------------------------------- diff --git a/downloads.html b/downloads.html index 9a2b856..3d5dd1d 100644 --- a/downloads.html +++ b/downloads.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="20180505" /> + <meta name="Date-Revision-yyyymmdd" content="20180506" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Apache HBase Downloads</title> <link rel="stylesheet" href="./css/apache-maven-fluido-1.5-HBASE.min.css" /> @@ -366,7 +366,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: 2018-05-05</li> + <li id="publishDate" class="pull-right">Last Published: 2018-05-06</li> </p> </div> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bbea48a/export_control.html ---------------------------------------------------------------------- diff --git a/export_control.html b/export_control.html index 4e37cae..9aa099d 100644 --- a/export_control.html +++ b/export_control.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="20180505" /> + <meta name="Date-Revision-yyyymmdd" content="20180506" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Export Control @@ -331,7 +331,7 @@ for more details.</p> <a href="https://www.apache.org/">The Apache Software Foundation</a>. All rights reserved. - <li id="publishDate" class="pull-right">Last Published: 2018-05-05</li> + <li id="publishDate" class="pull-right">Last Published: 2018-05-06</li> </p> </div>