This is an automated email from the ASF dual-hosted git repository.
git-site-role pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/hbase-site.git
The following commit(s) were added to refs/heads/asf-site by this push:
new bed5924a5a3 Published site at 460bb47c04cf2ffa71c23b80c5680d8cbb69234b.
bed5924a5a3 is described below
commit bed5924a5a36582315605ac9bcf0c288159768a6
Author: jenkins <[email protected]>
AuthorDate: Thu Sep 15 14:50:31 2022 +0000
Published site at 460bb47c04cf2ffa71c23b80c5680d8cbb69234b.
---
acid-semantics.html | 2 +-
apache_hbase_reference_guide.pdf | 4 +-
book.html | 2 +-
bulk-loads.html | 2 +-
checkstyle-aggregate.html | 2 +-
coc.html | 2 +-
dependencies.html | 2 +-
dependency-convergence.html | 2 +-
dependency-info.html | 2 +-
dependency-management.html | 2 +-
.../regionserver/RecoveredReplicationSource.html | 2 +-
.../regionserver/ReplicationSource.html | 52 +-
.../class-use/ReplicationSourceManager.html | 2 +-
.../regionserver/ReplicationSource.html | 560 ++++++++++-----------
downloads.html | 2 +-
export_control.html | 2 +-
index.html | 2 +-
issue-management.html | 2 +-
licenses.html | 2 +-
mailing-lists.html | 2 +-
metrics.html | 2 +-
old_news.html | 2 +-
plugin-management.html | 4 +-
plugins.html | 4 +-
poweredbyhbase.html | 2 +-
project-info.html | 2 +-
project-reports.html | 2 +-
pseudo-distributed.html | 2 +-
replication.html | 2 +-
resources.html | 2 +-
scm.html | 2 +-
sponsors.html | 2 +-
summary.html | 2 +-
supportingprojects.html | 2 +-
team.html | 2 +-
35 files changed, 338 insertions(+), 346 deletions(-)
diff --git a/acid-semantics.html b/acid-semantics.html
index b8965bc4f4f..d83ed0b7d9c 100644
--- a/acid-semantics.html
+++ b/acid-semantics.html
@@ -464,7 +464,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/apache_hbase_reference_guide.pdf b/apache_hbase_reference_guide.pdf
index c4a66f13cf5..185f64a9bb5 100644
--- a/apache_hbase_reference_guide.pdf
+++ b/apache_hbase_reference_guide.pdf
@@ -5,8 +5,8 @@
/Author (Apache HBase Team)
/Creator (Asciidoctor PDF 2.0.6, based on Prawn 2.4.0)
/Producer (Apache HBase Team)
-/ModDate (D:20220914151209+00'00')
-/CreationDate (D:20220914152300+00'00')
+/ModDate (D:20220915143708+00'00')
+/CreationDate (D:20220915144809+00'00')
>>
endobj
2 0 obj
diff --git a/book.html b/book.html
index 0e475aee8ab..c9da3513145 100644
--- a/book.html
+++ b/book.html
@@ -48002,7 +48002,7 @@
org/apache/hadoop/hbase/security/access/AccessControlClient.revoke:(Lorg/apache/
<div id="footer">
<div id="footer-text">
Version 3.0.0-alpha-4-SNAPSHOT<br>
-Last updated 2022-09-14 15:12:09 UTC
+Last updated 2022-09-15 14:37:08 UTC
</div>
</div>
<script type="text/x-mathjax-config">
diff --git a/bulk-loads.html b/bulk-loads.html
index fc7b1e7c8ad..a32dab1b314 100644
--- a/bulk-loads.html
+++ b/bulk-loads.html
@@ -180,7 +180,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/checkstyle-aggregate.html b/checkstyle-aggregate.html
index 02adb9d0485..1f1d9918c46 100644
--- a/checkstyle-aggregate.html
+++ b/checkstyle-aggregate.html
@@ -18729,7 +18729,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/coc.html b/coc.html
index 3ad52ca417b..6049e4d0f1b 100644
--- a/coc.html
+++ b/coc.html
@@ -248,7 +248,7 @@ email to <a class="externalLink"
href="mailto:[email protected]";>the priv
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/dependencies.html b/dependencies.html
index 3d729e59c67..16fc52e48b2 100644
--- a/dependencies.html
+++ b/dependencies.html
@@ -313,7 +313,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/dependency-convergence.html b/dependency-convergence.html
index 6341097dd76..a19d045a1f6 100644
--- a/dependency-convergence.html
+++ b/dependency-convergence.html
@@ -1013,7 +1013,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/dependency-info.html b/dependency-info.html
index 9fc8008b6c4..d5bb8925951 100644
--- a/dependency-info.html
+++ b/dependency-info.html
@@ -195,7 +195,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/dependency-management.html b/dependency-management.html
index ac19d8d5b5f..83658e598c8 100644
--- a/dependency-management.html
+++ b/dependency-management.html
@@ -1319,7 +1319,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/RecoveredReplicationSource.html
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/RecoveredReplicationSource.html
index b6d93bd6213..7f4c1a72de6 100644
---
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/RecoveredReplicationSource.html
+++
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/RecoveredReplicationSource.html
@@ -243,7 +243,7 @@ extends <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionser
<!-- -->
</a>
<h3>Methods inherited from
class org.apache.hadoop.hbase.replication.regionserver.<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSource</a></h3>
-<code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#addHFileRefs-org.apache.hadoop.hbase.TableName-byte:A-java.util.List-">addHFileRefs</a>,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#enqueueLog-org.apache.hadoop.fs.Path-">enqueueLog</a>,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getCurrentPath--">getCurrentPath</a>,
<a href [...]
+<code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#addHFileRefs-org.apache.hadoop.hbase.TableName-byte:A-java.util.List-">addHFileRefs</a>,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#enqueueLog-org.apache.hadoop.fs.Path-">enqueueLog</a>,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#getCurrentPath--">getCurrentPath</a>,
<a href [...]
</ul>
<ul class="blockList">
<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
diff --git
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
index 885fdfc0b8b..bcd2eeddc3e 100644
---
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
+++
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
@@ -560,7 +560,7 @@ implements <a
href="../../../../../../org/apache/hadoop/hbase/replication/region
</td>
</tr>
<tr id="i42" class="altColor">
-<td class="colFirst"><code>protected void</code></td>
+<td class="colFirst"><code>private void</code></td>
<td class="colLast"><code><span class="memberNameLink"><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#uncaughtException-java.lang.Thread-java.lang.Throwable-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager-java.lang.String-">uncaughtException</a></span>(<a
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true";
title="class or interface in java.lang">Thread</a> t,
<a
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true";
title="class or interface in java.lang">Throwable</a> e,
<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> manager,
@@ -1183,10 +1183,10 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>uncaughtException</h4>
-<pre>protected final void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.424">uncaughtException</a>(<a
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true";
title="class or interface in java.lang">Thread</a> t,
- <a
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true";
title="class or interface in java.lang">Throwable</a> e,
- <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> manager,
- <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> peerId)</pre>
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.424">uncaughtException</a>(<a
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true";
title="class or interface in java.lang">Thread</a> t,
+ <a
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true";
title="class or interface in java.lang">Throwable</a> e,
+ <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> manager,
+ <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> peerId)</pre>
</li>
</ul>
<a name="getReplicationEndpoint--">
@@ -1290,7 +1290,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>setSourceStartupStatus</h4>
-<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.591">setSourceStartupStatus</a>(boolean initializing)</pre>
+<pre>private void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.583">setSourceStartupStatus</a>(boolean initializing)</pre>
</li>
</ul>
<a name="startup--">
@@ -1299,7 +1299,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>startup</h4>
-<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.601">startup</a>()</pre>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.593">startup</a>()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#startup--">ReplicationSourceInterface</a></code></span></div>
<div class="block">Start the replication</div>
<dl>
@@ -1314,7 +1314,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>terminate</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.635">terminate</a>(<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> reason)</pre>
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.627">terminate</a>(<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> reason)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#terminate-java.lang.String-">ReplicationSourceInterface</a></code></span></div>
<div class="block">End the replication</div>
<dl>
@@ -1331,7 +1331,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>terminate</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.640">terminate</a>(<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> reason,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.632">terminate</a>(<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> reason,
<a
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true";
title="class or interface in java.lang">Exception</a> cause)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#terminate-java.lang.String-java.lang.Exception-">ReplicationSourceInterface</a></code></span></div>
<div class="block">End the replication</div>
@@ -1350,7 +1350,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>terminate</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.645">terminate</a>(<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> reason,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.637">terminate</a>(<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> reason,
<a
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true";
title="class or interface in java.lang">Exception</a> cause,
boolean clearMetrics)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#terminate-java.lang.String-java.lang.Exception-boolean-">ReplicationSourceInterface</a></code></span></div>
@@ -1371,7 +1371,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>terminate</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.649">terminate</a>(<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> reason,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.641">terminate</a>(<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> reason,
<a
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true";
title="class or interface in java.lang">Exception</a> cause,
boolean clearMetrics,
boolean join)</pre>
@@ -1383,7 +1383,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>getQueueId</h4>
-<pre>public <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> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.726">getQueueId</a>()</pre>
+<pre>public <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> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.718">getQueueId</a>()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getQueueId--">ReplicationSourceInterface</a></code></span></div>
<div class="block">Get the queue id that the source is replicating to</div>
<dl>
@@ -1400,7 +1400,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>getCurrentPath</h4>
-<pre>public org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.731">getCurrentPath</a>()</pre>
+<pre>public org.apache.hadoop.fs.Path <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.723">getCurrentPath</a>()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getCurrentPath--">ReplicationSourceInterface</a></code></span></div>
<div class="block">Get the current log that's replicated</div>
<dl>
@@ -1417,7 +1417,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>isSourceActive</h4>
-<pre>public boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.742">isSourceActive</a>()</pre>
+<pre>public boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.734">isSourceActive</a>()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#isSourceActive--">ReplicationSourceInterface</a></code></span></div>
<div class="block">Returns active or not</div>
<dl>
@@ -1432,7 +1432,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>getReplicationQueueInfo</h4>
-<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueInfo.html"
title="class in
org.apache.hadoop.hbase.replication">ReplicationQueueInfo</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.746">getReplicationQueueInfo</a>()</pre>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueInfo.html"
title="class in
org.apache.hadoop.hbase.replication">ReplicationQueueInfo</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.738">getReplicationQueueInfo</a>()</pre>
</li>
</ul>
<a name="isWorkerRunning--">
@@ -1441,7 +1441,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>isWorkerRunning</h4>
-<pre>public boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.750">isWorkerRunning</a>()</pre>
+<pre>public boolean <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.742">isWorkerRunning</a>()</pre>
</li>
</ul>
<a name="getStats--">
@@ -1450,7 +1450,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>getStats</h4>
-<pre>public <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> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.760">getStats</a>()</pre>
+<pre>public <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> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.752">getStats</a>()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getStats--">ReplicationSourceInterface</a></code></span></div>
<div class="block">Get a string representation of the current statistics for
this source</div>
<dl>
@@ -1467,7 +1467,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>getSourceMetrics</h4>
-<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.781">getSourceMetrics</a>()</pre>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.773">getSourceMetrics</a>()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getSourceMetrics--">ReplicationSourceInterface</a></code></span></div>
<div class="block">Returns metrics of this replication source</div>
<dl>
@@ -1482,7 +1482,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>postShipEdits</h4>
-<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.787">postShipEdits</a>(<a
href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<a
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html"
title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a>> entries,
+<pre>public void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.779">postShipEdits</a>(<a
href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
title="class or interface in java.util">List</a><<a
href="../../../../../../org/apache/hadoop/hbase/wal/WAL.Entry.html"
title="class in org.apache.hadoop.hbase.wal">WAL.Entry</a>> entries,
int batchSize)</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#postShipEdits-java.util.List-int-">ReplicationSourceInterface</a></code></span></div>
<div class="block">Call this after the shipper thread ship some entries to
peer cluster.</div>
@@ -1501,7 +1501,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>getWALFileLengthProvider</h4>
-<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALFileLengthProvider.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">WALFileLengthProvider</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.798">getWALFileLengthProvider</a>()</pre>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALFileLengthProvider.html"
title="interface in
org.apache.hadoop.hbase.replication.regionserver">WALFileLengthProvider</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.790">getWALFileLengthProvider</a>()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getWALFileLengthProvider--">ReplicationSourceInterface</a></code></span></div>
<div class="block">Returns the wal file length provider</div>
<dl>
@@ -1516,7 +1516,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>getServerWALsBelongTo</h4>
-<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class
in org.apache.hadoop.hbase">ServerName</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.803">getServerWALsBelongTo</a>()</pre>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class
in org.apache.hadoop.hbase">ServerName</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.795">getServerWALsBelongTo</a>()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getServerWALsBelongTo--">ReplicationSourceInterface</a></code></span></div>
<div class="block">The queue of WALs only belong to one region server. This
will return the server name which all
WALs belong to.</div>
@@ -1534,7 +1534,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>getPeer</h4>
-<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationPeer</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.808">getPeer</a>()</pre>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationPeer</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.800">getPeer</a>()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getPeer--">ReplicationSourceInterface</a></code></span></div>
<div class="block">Get the replication peer instance.</div>
<dl>
@@ -1551,7 +1551,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>getServer</h4>
-<pre><a href="../../../../../../org/apache/hadoop/hbase/Server.html"
title="interface in org.apache.hadoop.hbase">Server</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.812">getServer</a>()</pre>
+<pre><a href="../../../../../../org/apache/hadoop/hbase/Server.html"
title="interface in org.apache.hadoop.hbase">Server</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.804">getServer</a>()</pre>
</li>
</ul>
<a name="getReplicationQueueStorage--">
@@ -1560,7 +1560,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>getReplicationQueueStorage</h4>
-<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.817">getReplicationQueueStorage</a>()</pre>
+<pre>public <a
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
title="interface in
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.809">getReplicationQueueStorage</a>()</pre>
<div class="block"><span class="descfrmTypeLabel">Description copied from
interface: <code><a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html#getReplicationQueueStorage--">ReplicationSourceInterface</a></code></span></div>
<div class="block">Returns The instance of queueStorage used by this
ReplicationSource.</div>
<dl>
@@ -1575,7 +1575,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockList">
<li class="blockList">
<h4>removeWorker</h4>
-<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.821">removeWorker</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper</a> worker)</pre>
+<pre>void <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.813">removeWorker</a>(<a
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceShipper</a> worker)</pre>
</li>
</ul>
<a name="logPeerId--">
@@ -1584,7 +1584,7 @@ public <a
href="https://docs.oracle.com/javase/8/docs/api/java/util/Map.htm
<ul class="blockListLast">
<li class="blockList">
<h4>logPeerId</h4>
-<pre>public <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> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.825">logPeerId</a>()</pre>
+<pre>public <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> <a
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#line.817">logPeerId</a>()</pre>
</li>
</ul>
</li>
diff --git
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/class-use/ReplicationSourceManager.html
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/class-use/ReplicationSourceManager.html
index c9e67724ae3..948f83d6811 100644
---
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/class-use/ReplicationSourceManager.html
+++
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/class-use/ReplicationSourceManager.html
@@ -225,7 +225,7 @@
<a
href="../../../../../../../org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">MetricsSource</a> metrics)</code> </td>
</tr>
<tr class="altColor">
-<td class="colFirst"><code>protected void</code></td>
+<td class="colFirst"><code>private void</code></td>
<td class="colLast"><span
class="typeNameLabel">ReplicationSource.</span><code><span
class="memberNameLink"><a
href="../../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html#uncaughtException-java.lang.Thread-java.lang.Throwable-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager-java.lang.String-">uncaughtException</a></span>(<a
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true";
title="class o [...]
<a
href="https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true";
title="class or interface in java.lang">Throwable</a> e,
<a
href="../../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html"
title="class in
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager</a> manager,
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
index 3675d60e2c8..b024807deb0 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html
@@ -429,7 +429,7 @@
<span class="sourceLineNo">421</span> return walEntryFilter;<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> protected final void
uncaughtException(Thread t, Throwable e, ReplicationSourceManager manager,<a
name="line.424"></a>
+<span class="sourceLineNo">424</span> private void uncaughtException(Thread
t, Throwable e, ReplicationSourceManager manager,<a name="line.424"></a>
<span class="sourceLineNo">425</span> String peerId) {<a
name="line.425"></a>
<span class="sourceLineNo">426</span> OOMEChecker.exitIfOOME(e,
getClass().getSimpleName());<a name="line.426"></a>
<span class="sourceLineNo">427</span> LOG.error("Unexpected exception in {}
currentPath={}", t.getName(), getCurrentPath(), e);<a name="line.427"></a>
@@ -547,293 +547,285 @@
<span class="sourceLineNo">539</span> }<a name="line.539"></a>
<span class="sourceLineNo">540</span><a name="line.540"></a>
<span class="sourceLineNo">541</span> if (!this.isSourceActive()) {<a
name="line.541"></a>
-<span class="sourceLineNo">542</span> setSourceStartupStatus(false);<a
name="line.542"></a>
-<span class="sourceLineNo">543</span> if
(Thread.currentThread().isInterrupted()) {<a name="line.543"></a>
-<span class="sourceLineNo">544</span> // If source is not running and
thread is interrupted this means someone has tried to<a name="line.544"></a>
-<span class="sourceLineNo">545</span> // remove this peer.<a
name="line.545"></a>
-<span class="sourceLineNo">546</span> return;<a name="line.546"></a>
-<span class="sourceLineNo">547</span> }<a name="line.547"></a>
-<span class="sourceLineNo">548</span><a name="line.548"></a>
-<span class="sourceLineNo">549</span>
retryStartup.set(!this.abortOnError);<a name="line.549"></a>
-<span class="sourceLineNo">550</span> throw new
IllegalStateException("Source should be active.");<a name="line.550"></a>
-<span class="sourceLineNo">551</span> }<a name="line.551"></a>
-<span class="sourceLineNo">552</span><a name="line.552"></a>
-<span class="sourceLineNo">553</span> sleepMultiplier = 1;<a
name="line.553"></a>
-<span class="sourceLineNo">554</span> UUID peerClusterId;<a
name="line.554"></a>
-<span class="sourceLineNo">555</span> // delay this until we are in an
asynchronous thread<a name="line.555"></a>
-<span class="sourceLineNo">556</span> for (;;) {<a name="line.556"></a>
-<span class="sourceLineNo">557</span> peerClusterId =
replicationEndpoint.getPeerUUID();<a name="line.557"></a>
-<span class="sourceLineNo">558</span> if (this.isSourceActive()
&& peerClusterId == null) {<a name="line.558"></a>
-<span class="sourceLineNo">559</span> if (LOG.isDebugEnabled()) {<a
name="line.559"></a>
-<span class="sourceLineNo">560</span> LOG.debug("{} Could not connect
to Peer ZK. Sleeping for {} millis", logPeerId(),<a name="line.560"></a>
-<span class="sourceLineNo">561</span> (this.sleepForRetries *
sleepMultiplier));<a name="line.561"></a>
-<span class="sourceLineNo">562</span> }<a name="line.562"></a>
-<span class="sourceLineNo">563</span> if (sleepForRetries("Cannot
contact the peer's zk ensemble", sleepMultiplier)) {<a name="line.563"></a>
-<span class="sourceLineNo">564</span> sleepMultiplier++;<a
name="line.564"></a>
-<span class="sourceLineNo">565</span> }<a name="line.565"></a>
-<span class="sourceLineNo">566</span> } else {<a name="line.566"></a>
-<span class="sourceLineNo">567</span> break;<a name="line.567"></a>
-<span class="sourceLineNo">568</span> }<a name="line.568"></a>
-<span class="sourceLineNo">569</span> }<a name="line.569"></a>
-<span class="sourceLineNo">570</span><a name="line.570"></a>
-<span class="sourceLineNo">571</span> if (!this.isSourceActive()) {<a
name="line.571"></a>
-<span class="sourceLineNo">572</span> setSourceStartupStatus(false);<a
name="line.572"></a>
-<span class="sourceLineNo">573</span> if
(Thread.currentThread().isInterrupted()) {<a name="line.573"></a>
-<span class="sourceLineNo">574</span> // If source is not running and
thread is interrupted this means someone has tried to<a name="line.574"></a>
-<span class="sourceLineNo">575</span> // remove this peer.<a
name="line.575"></a>
-<span class="sourceLineNo">576</span> return;<a name="line.576"></a>
-<span class="sourceLineNo">577</span> }<a name="line.577"></a>
-<span class="sourceLineNo">578</span>
retryStartup.set(!this.abortOnError);<a name="line.578"></a>
-<span class="sourceLineNo">579</span> throw new
IllegalStateException("Source should be active.");<a name="line.579"></a>
-<span class="sourceLineNo">580</span> }<a name="line.580"></a>
-<span class="sourceLineNo">581</span> LOG.info("{} queueId={} (queues={})
is replicating from cluster={} to cluster={}", logPeerId(),<a
name="line.581"></a>
-<span class="sourceLineNo">582</span>
this.replicationQueueInfo.getQueueId(), logQueue.getNumQueues(), clusterId,
peerClusterId);<a name="line.582"></a>
-<span class="sourceLineNo">583</span>
initializeWALEntryFilter(peerClusterId);<a name="line.583"></a>
-<span class="sourceLineNo">584</span> // Start workers<a
name="line.584"></a>
-<span class="sourceLineNo">585</span> for (String walGroupId :
logQueue.getQueues().keySet()) {<a name="line.585"></a>
-<span class="sourceLineNo">586</span> tryStartNewShipper(walGroupId);<a
name="line.586"></a>
-<span class="sourceLineNo">587</span> }<a name="line.587"></a>
-<span class="sourceLineNo">588</span> setSourceStartupStatus(false);<a
name="line.588"></a>
-<span class="sourceLineNo">589</span> }<a name="line.589"></a>
-<span class="sourceLineNo">590</span><a name="line.590"></a>
-<span class="sourceLineNo">591</span> private synchronized void
setSourceStartupStatus(boolean initializing) {<a name="line.591"></a>
-<span class="sourceLineNo">592</span> startupOngoing.set(initializing);<a
name="line.592"></a>
-<span class="sourceLineNo">593</span> if (initializing) {<a
name="line.593"></a>
-<span class="sourceLineNo">594</span> metrics.incrSourceInitializing();<a
name="line.594"></a>
-<span class="sourceLineNo">595</span> } else {<a name="line.595"></a>
-<span class="sourceLineNo">596</span> metrics.decrSourceInitializing();<a
name="line.596"></a>
-<span class="sourceLineNo">597</span> }<a name="line.597"></a>
-<span class="sourceLineNo">598</span> }<a name="line.598"></a>
-<span class="sourceLineNo">599</span><a name="line.599"></a>
-<span class="sourceLineNo">600</span> @Override<a name="line.600"></a>
-<span class="sourceLineNo">601</span> public ReplicationSourceInterface
startup() {<a name="line.601"></a>
-<span class="sourceLineNo">602</span> if (this.sourceRunning) {<a
name="line.602"></a>
-<span class="sourceLineNo">603</span> return this;<a name="line.603"></a>
-<span class="sourceLineNo">604</span> }<a name="line.604"></a>
-<span class="sourceLineNo">605</span> this.sourceRunning = true;<a
name="line.605"></a>
-<span class="sourceLineNo">606</span> setSourceStartupStatus(true);<a
name="line.606"></a>
-<span class="sourceLineNo">607</span> initThread = new
Thread(this::initialize);<a name="line.607"></a>
-<span class="sourceLineNo">608</span>
Threads.setDaemonThreadRunning(initThread,<a name="line.608"></a>
-<span class="sourceLineNo">609</span> Thread.currentThread().getName() +
".replicationSource," + this.queueId, (t, e) -> {<a name="line.609"></a>
-<span class="sourceLineNo">610</span> // if first initialization
attempt failed, and abortOnError is false, we will<a name="line.610"></a>
-<span class="sourceLineNo">611</span> // keep looping in this thread
until initialize eventually succeeds,<a name="line.611"></a>
-<span class="sourceLineNo">612</span> // while the server main startup
one can go on with its work.<a name="line.612"></a>
-<span class="sourceLineNo">613</span> sourceRunning = false;<a
name="line.613"></a>
-<span class="sourceLineNo">614</span> uncaughtException(t, e, null,
null);<a name="line.614"></a>
-<span class="sourceLineNo">615</span>
retryStartup.set(!this.abortOnError);<a name="line.615"></a>
-<span class="sourceLineNo">616</span> do {<a name="line.616"></a>
-<span class="sourceLineNo">617</span> if (retryStartup.get()) {<a
name="line.617"></a>
-<span class="sourceLineNo">618</span> this.sourceRunning = true;<a
name="line.618"></a>
-<span class="sourceLineNo">619</span>
setSourceStartupStatus(true);<a name="line.619"></a>
-<span class="sourceLineNo">620</span> retryStartup.set(false);<a
name="line.620"></a>
-<span class="sourceLineNo">621</span> try {<a name="line.621"></a>
-<span class="sourceLineNo">622</span> initialize();<a
name="line.622"></a>
-<span class="sourceLineNo">623</span> } catch (Throwable error) {<a
name="line.623"></a>
-<span class="sourceLineNo">624</span>
setSourceStartupStatus(false);<a name="line.624"></a>
-<span class="sourceLineNo">625</span> uncaughtException(t, error,
null, null);<a name="line.625"></a>
-<span class="sourceLineNo">626</span>
retryStartup.set(!this.abortOnError);<a name="line.626"></a>
-<span class="sourceLineNo">627</span> }<a name="line.627"></a>
-<span class="sourceLineNo">628</span> }<a name="line.628"></a>
-<span class="sourceLineNo">629</span> } while
((this.startupOngoing.get() || this.retryStartup.get()) &&
!this.abortOnError);<a name="line.629"></a>
-<span class="sourceLineNo">630</span> });<a name="line.630"></a>
-<span class="sourceLineNo">631</span> return this;<a name="line.631"></a>
-<span class="sourceLineNo">632</span> }<a name="line.632"></a>
-<span class="sourceLineNo">633</span><a name="line.633"></a>
-<span class="sourceLineNo">634</span> @Override<a name="line.634"></a>
-<span class="sourceLineNo">635</span> public void terminate(String reason)
{<a name="line.635"></a>
-<span class="sourceLineNo">636</span> terminate(reason, null);<a
name="line.636"></a>
-<span class="sourceLineNo">637</span> }<a name="line.637"></a>
-<span class="sourceLineNo">638</span><a name="line.638"></a>
-<span class="sourceLineNo">639</span> @Override<a name="line.639"></a>
-<span class="sourceLineNo">640</span> public void terminate(String reason,
Exception cause) {<a name="line.640"></a>
-<span class="sourceLineNo">641</span> terminate(reason, cause, true);<a
name="line.641"></a>
-<span class="sourceLineNo">642</span> }<a name="line.642"></a>
-<span class="sourceLineNo">643</span><a name="line.643"></a>
-<span class="sourceLineNo">644</span> @Override<a name="line.644"></a>
-<span class="sourceLineNo">645</span> public void terminate(String reason,
Exception cause, boolean clearMetrics) {<a name="line.645"></a>
-<span class="sourceLineNo">646</span> terminate(reason, cause,
clearMetrics, true);<a name="line.646"></a>
-<span class="sourceLineNo">647</span> }<a name="line.647"></a>
-<span class="sourceLineNo">648</span><a name="line.648"></a>
-<span class="sourceLineNo">649</span> public void terminate(String reason,
Exception cause, boolean clearMetrics, boolean join) {<a name="line.649"></a>
-<span class="sourceLineNo">650</span> if (cause == null) {<a
name="line.650"></a>
-<span class="sourceLineNo">651</span> LOG.info("{} Closing source {}
because: {}", logPeerId(), this.queueId, reason);<a name="line.651"></a>
-<span class="sourceLineNo">652</span> } else {<a name="line.652"></a>
-<span class="sourceLineNo">653</span> LOG.error(String.format("%s Closing
source %s because an error occurred: %s", logPeerId(),<a name="line.653"></a>
-<span class="sourceLineNo">654</span> this.queueId, reason), cause);<a
name="line.654"></a>
+<span class="sourceLineNo">542</span> // this means the server is
shutting down or the source is terminated, just give up<a name="line.542"></a>
+<span class="sourceLineNo">543</span> // initializing<a
name="line.543"></a>
+<span class="sourceLineNo">544</span> setSourceStartupStatus(false);<a
name="line.544"></a>
+<span class="sourceLineNo">545</span> return;<a name="line.545"></a>
+<span class="sourceLineNo">546</span> }<a name="line.546"></a>
+<span class="sourceLineNo">547</span><a name="line.547"></a>
+<span class="sourceLineNo">548</span> sleepMultiplier = 1;<a
name="line.548"></a>
+<span class="sourceLineNo">549</span> UUID peerClusterId;<a
name="line.549"></a>
+<span class="sourceLineNo">550</span> // delay this until we are in an
asynchronous thread<a name="line.550"></a>
+<span class="sourceLineNo">551</span> for (;;) {<a name="line.551"></a>
+<span class="sourceLineNo">552</span> peerClusterId =
replicationEndpoint.getPeerUUID();<a name="line.552"></a>
+<span class="sourceLineNo">553</span> if (this.isSourceActive()
&& peerClusterId == null) {<a name="line.553"></a>
+<span class="sourceLineNo">554</span> if (LOG.isDebugEnabled()) {<a
name="line.554"></a>
+<span class="sourceLineNo">555</span> LOG.debug("{} Could not connect
to Peer ZK. Sleeping for {} millis", logPeerId(),<a name="line.555"></a>
+<span class="sourceLineNo">556</span> (this.sleepForRetries *
sleepMultiplier));<a name="line.556"></a>
+<span class="sourceLineNo">557</span> }<a name="line.557"></a>
+<span class="sourceLineNo">558</span> if (sleepForRetries("Cannot
contact the peer's zk ensemble", sleepMultiplier)) {<a name="line.558"></a>
+<span class="sourceLineNo">559</span> sleepMultiplier++;<a
name="line.559"></a>
+<span class="sourceLineNo">560</span> }<a name="line.560"></a>
+<span class="sourceLineNo">561</span> } else {<a name="line.561"></a>
+<span class="sourceLineNo">562</span> break;<a name="line.562"></a>
+<span class="sourceLineNo">563</span> }<a name="line.563"></a>
+<span class="sourceLineNo">564</span> }<a name="line.564"></a>
+<span class="sourceLineNo">565</span><a name="line.565"></a>
+<span class="sourceLineNo">566</span> if (!this.isSourceActive()) {<a
name="line.566"></a>
+<span class="sourceLineNo">567</span> // this means the server is
shutting down or the source is terminated, just give up<a name="line.567"></a>
+<span class="sourceLineNo">568</span> // initializing<a
name="line.568"></a>
+<span class="sourceLineNo">569</span> setSourceStartupStatus(false);<a
name="line.569"></a>
+<span class="sourceLineNo">570</span> return;<a name="line.570"></a>
+<span class="sourceLineNo">571</span> }<a name="line.571"></a>
+<span class="sourceLineNo">572</span><a name="line.572"></a>
+<span class="sourceLineNo">573</span> LOG.info("{} queueId={} (queues={})
is replicating from cluster={} to cluster={}", logPeerId(),<a
name="line.573"></a>
+<span class="sourceLineNo">574</span>
this.replicationQueueInfo.getQueueId(), logQueue.getNumQueues(), clusterId,
peerClusterId);<a name="line.574"></a>
+<span class="sourceLineNo">575</span>
initializeWALEntryFilter(peerClusterId);<a name="line.575"></a>
+<span class="sourceLineNo">576</span> // Start workers<a
name="line.576"></a>
+<span class="sourceLineNo">577</span> for (String walGroupId :
logQueue.getQueues().keySet()) {<a name="line.577"></a>
+<span class="sourceLineNo">578</span> tryStartNewShipper(walGroupId);<a
name="line.578"></a>
+<span class="sourceLineNo">579</span> }<a name="line.579"></a>
+<span class="sourceLineNo">580</span> setSourceStartupStatus(false);<a
name="line.580"></a>
+<span class="sourceLineNo">581</span> }<a name="line.581"></a>
+<span class="sourceLineNo">582</span><a name="line.582"></a>
+<span class="sourceLineNo">583</span> private synchronized void
setSourceStartupStatus(boolean initializing) {<a name="line.583"></a>
+<span class="sourceLineNo">584</span> startupOngoing.set(initializing);<a
name="line.584"></a>
+<span class="sourceLineNo">585</span> if (initializing) {<a
name="line.585"></a>
+<span class="sourceLineNo">586</span> metrics.incrSourceInitializing();<a
name="line.586"></a>
+<span class="sourceLineNo">587</span> } else {<a name="line.587"></a>
+<span class="sourceLineNo">588</span> metrics.decrSourceInitializing();<a
name="line.588"></a>
+<span class="sourceLineNo">589</span> }<a name="line.589"></a>
+<span class="sourceLineNo">590</span> }<a name="line.590"></a>
+<span class="sourceLineNo">591</span><a name="line.591"></a>
+<span class="sourceLineNo">592</span> @Override<a name="line.592"></a>
+<span class="sourceLineNo">593</span> public ReplicationSourceInterface
startup() {<a name="line.593"></a>
+<span class="sourceLineNo">594</span> if (this.sourceRunning) {<a
name="line.594"></a>
+<span class="sourceLineNo">595</span> return this;<a name="line.595"></a>
+<span class="sourceLineNo">596</span> }<a name="line.596"></a>
+<span class="sourceLineNo">597</span> this.sourceRunning = true;<a
name="line.597"></a>
+<span class="sourceLineNo">598</span> setSourceStartupStatus(true);<a
name="line.598"></a>
+<span class="sourceLineNo">599</span> initThread = new
Thread(this::initialize);<a name="line.599"></a>
+<span class="sourceLineNo">600</span>
Threads.setDaemonThreadRunning(initThread,<a name="line.600"></a>
+<span class="sourceLineNo">601</span> Thread.currentThread().getName() +
".replicationSource," + this.queueId, (t, e) -> {<a name="line.601"></a>
+<span class="sourceLineNo">602</span> // if first initialization
attempt failed, and abortOnError is false, we will<a name="line.602"></a>
+<span class="sourceLineNo">603</span> // keep looping in this thread
until initialize eventually succeeds,<a name="line.603"></a>
+<span class="sourceLineNo">604</span> // while the server main startup
one can go on with its work.<a name="line.604"></a>
+<span class="sourceLineNo">605</span> sourceRunning = false;<a
name="line.605"></a>
+<span class="sourceLineNo">606</span> uncaughtException(t, e, null,
null);<a name="line.606"></a>
+<span class="sourceLineNo">607</span>
retryStartup.set(!this.abortOnError);<a name="line.607"></a>
+<span class="sourceLineNo">608</span> do {<a name="line.608"></a>
+<span class="sourceLineNo">609</span> if (retryStartup.get()) {<a
name="line.609"></a>
+<span class="sourceLineNo">610</span> this.sourceRunning = true;<a
name="line.610"></a>
+<span class="sourceLineNo">611</span>
setSourceStartupStatus(true);<a name="line.611"></a>
+<span class="sourceLineNo">612</span> retryStartup.set(false);<a
name="line.612"></a>
+<span class="sourceLineNo">613</span> try {<a name="line.613"></a>
+<span class="sourceLineNo">614</span> initialize();<a
name="line.614"></a>
+<span class="sourceLineNo">615</span> } catch (Throwable error) {<a
name="line.615"></a>
+<span class="sourceLineNo">616</span>
setSourceStartupStatus(false);<a name="line.616"></a>
+<span class="sourceLineNo">617</span> uncaughtException(t, error,
null, null);<a name="line.617"></a>
+<span class="sourceLineNo">618</span>
retryStartup.set(!this.abortOnError);<a name="line.618"></a>
+<span class="sourceLineNo">619</span> }<a name="line.619"></a>
+<span class="sourceLineNo">620</span> }<a name="line.620"></a>
+<span class="sourceLineNo">621</span> } while
((this.startupOngoing.get() || this.retryStartup.get()) &&
!this.abortOnError);<a name="line.621"></a>
+<span class="sourceLineNo">622</span> });<a name="line.622"></a>
+<span class="sourceLineNo">623</span> return this;<a name="line.623"></a>
+<span class="sourceLineNo">624</span> }<a name="line.624"></a>
+<span class="sourceLineNo">625</span><a name="line.625"></a>
+<span class="sourceLineNo">626</span> @Override<a name="line.626"></a>
+<span class="sourceLineNo">627</span> public void terminate(String reason)
{<a name="line.627"></a>
+<span class="sourceLineNo">628</span> terminate(reason, null);<a
name="line.628"></a>
+<span class="sourceLineNo">629</span> }<a name="line.629"></a>
+<span class="sourceLineNo">630</span><a name="line.630"></a>
+<span class="sourceLineNo">631</span> @Override<a name="line.631"></a>
+<span class="sourceLineNo">632</span> public void terminate(String reason,
Exception cause) {<a name="line.632"></a>
+<span class="sourceLineNo">633</span> terminate(reason, cause, true);<a
name="line.633"></a>
+<span class="sourceLineNo">634</span> }<a name="line.634"></a>
+<span class="sourceLineNo">635</span><a name="line.635"></a>
+<span class="sourceLineNo">636</span> @Override<a name="line.636"></a>
+<span class="sourceLineNo">637</span> public void terminate(String reason,
Exception cause, boolean clearMetrics) {<a name="line.637"></a>
+<span class="sourceLineNo">638</span> terminate(reason, cause,
clearMetrics, true);<a name="line.638"></a>
+<span class="sourceLineNo">639</span> }<a name="line.639"></a>
+<span class="sourceLineNo">640</span><a name="line.640"></a>
+<span class="sourceLineNo">641</span> public void terminate(String reason,
Exception cause, boolean clearMetrics, boolean join) {<a name="line.641"></a>
+<span class="sourceLineNo">642</span> if (cause == null) {<a
name="line.642"></a>
+<span class="sourceLineNo">643</span> LOG.info("{} Closing source {}
because: {}", logPeerId(), this.queueId, reason);<a name="line.643"></a>
+<span class="sourceLineNo">644</span> } else {<a name="line.644"></a>
+<span class="sourceLineNo">645</span> LOG.error(String.format("%s Closing
source %s because an error occurred: %s", logPeerId(),<a name="line.645"></a>
+<span class="sourceLineNo">646</span> this.queueId, reason), cause);<a
name="line.646"></a>
+<span class="sourceLineNo">647</span> }<a name="line.647"></a>
+<span class="sourceLineNo">648</span> this.sourceRunning = false;<a
name="line.648"></a>
+<span class="sourceLineNo">649</span> if (initThread != null &&
Thread.currentThread() != initThread) {<a name="line.649"></a>
+<span class="sourceLineNo">650</span> // This usually won't happen but
anyway, let's wait until the initialization thread exits.<a name="line.650"></a>
+<span class="sourceLineNo">651</span> // And notice that we may call
terminate directly from the initThread so here we need to<a name="line.651"></a>
+<span class="sourceLineNo">652</span> // avoid join on ourselves.<a
name="line.652"></a>
+<span class="sourceLineNo">653</span> initThread.interrupt();<a
name="line.653"></a>
+<span class="sourceLineNo">654</span> Threads.shutdown(initThread,
this.sleepForRetries);<a name="line.654"></a>
<span class="sourceLineNo">655</span> }<a name="line.655"></a>
-<span class="sourceLineNo">656</span> this.sourceRunning = false;<a
name="line.656"></a>
-<span class="sourceLineNo">657</span> if (initThread != null &&
Thread.currentThread() != initThread) {<a name="line.657"></a>
-<span class="sourceLineNo">658</span> // This usually won't happen but
anyway, let's wait until the initialization thread exits.<a name="line.658"></a>
-<span class="sourceLineNo">659</span> // And notice that we may call
terminate directly from the initThread so here we need to<a name="line.659"></a>
-<span class="sourceLineNo">660</span> // avoid join on ourselves.<a
name="line.660"></a>
-<span class="sourceLineNo">661</span> initThread.interrupt();<a
name="line.661"></a>
-<span class="sourceLineNo">662</span> Threads.shutdown(initThread,
this.sleepForRetries);<a name="line.662"></a>
+<span class="sourceLineNo">656</span>
Collection<ReplicationSourceShipper> workers = workerThreads.values();<a
name="line.656"></a>
+<span class="sourceLineNo">657</span><a name="line.657"></a>
+<span class="sourceLineNo">658</span> for (ReplicationSourceShipper worker
: workers) {<a name="line.658"></a>
+<span class="sourceLineNo">659</span> worker.stopWorker();<a
name="line.659"></a>
+<span class="sourceLineNo">660</span> if (worker.entryReader != null) {<a
name="line.660"></a>
+<span class="sourceLineNo">661</span>
worker.entryReader.setReaderRunning(false);<a name="line.661"></a>
+<span class="sourceLineNo">662</span> }<a name="line.662"></a>
<span class="sourceLineNo">663</span> }<a name="line.663"></a>
-<span class="sourceLineNo">664</span>
Collection<ReplicationSourceShipper> workers = workerThreads.values();<a
name="line.664"></a>
-<span class="sourceLineNo">665</span><a name="line.665"></a>
-<span class="sourceLineNo">666</span> for (ReplicationSourceShipper worker
: workers) {<a name="line.666"></a>
-<span class="sourceLineNo">667</span> worker.stopWorker();<a
name="line.667"></a>
-<span class="sourceLineNo">668</span> if (worker.entryReader != null) {<a
name="line.668"></a>
-<span class="sourceLineNo">669</span>
worker.entryReader.setReaderRunning(false);<a name="line.669"></a>
-<span class="sourceLineNo">670</span> }<a name="line.670"></a>
-<span class="sourceLineNo">671</span> }<a name="line.671"></a>
-<span class="sourceLineNo">672</span><a name="line.672"></a>
-<span class="sourceLineNo">673</span> if (this.replicationEndpoint != null)
{<a name="line.673"></a>
-<span class="sourceLineNo">674</span> this.replicationEndpoint.stop();<a
name="line.674"></a>
-<span class="sourceLineNo">675</span> }<a name="line.675"></a>
-<span class="sourceLineNo">676</span><a name="line.676"></a>
-<span class="sourceLineNo">677</span> for (ReplicationSourceShipper worker
: workers) {<a name="line.677"></a>
-<span class="sourceLineNo">678</span> if (worker.isAlive() ||
worker.entryReader.isAlive()) {<a name="line.678"></a>
-<span class="sourceLineNo">679</span> try {<a name="line.679"></a>
-<span class="sourceLineNo">680</span> // Wait worker to stop<a
name="line.680"></a>
-<span class="sourceLineNo">681</span>
Thread.sleep(this.sleepForRetries);<a name="line.681"></a>
-<span class="sourceLineNo">682</span> } catch (InterruptedException e)
{<a name="line.682"></a>
-<span class="sourceLineNo">683</span> LOG.info("{} Interrupted while
waiting {} to stop", logPeerId(), worker.getName());<a name="line.683"></a>
-<span class="sourceLineNo">684</span>
Thread.currentThread().interrupt();<a name="line.684"></a>
+<span class="sourceLineNo">664</span><a name="line.664"></a>
+<span class="sourceLineNo">665</span> if (this.replicationEndpoint != null)
{<a name="line.665"></a>
+<span class="sourceLineNo">666</span> this.replicationEndpoint.stop();<a
name="line.666"></a>
+<span class="sourceLineNo">667</span> }<a name="line.667"></a>
+<span class="sourceLineNo">668</span><a name="line.668"></a>
+<span class="sourceLineNo">669</span> for (ReplicationSourceShipper worker
: workers) {<a name="line.669"></a>
+<span class="sourceLineNo">670</span> if (worker.isAlive() ||
worker.entryReader.isAlive()) {<a name="line.670"></a>
+<span class="sourceLineNo">671</span> try {<a name="line.671"></a>
+<span class="sourceLineNo">672</span> // Wait worker to stop<a
name="line.672"></a>
+<span class="sourceLineNo">673</span>
Thread.sleep(this.sleepForRetries);<a name="line.673"></a>
+<span class="sourceLineNo">674</span> } catch (InterruptedException e)
{<a name="line.674"></a>
+<span class="sourceLineNo">675</span> LOG.info("{} Interrupted while
waiting {} to stop", logPeerId(), worker.getName());<a name="line.675"></a>
+<span class="sourceLineNo">676</span>
Thread.currentThread().interrupt();<a name="line.676"></a>
+<span class="sourceLineNo">677</span> }<a name="line.677"></a>
+<span class="sourceLineNo">678</span> // If worker still is alive after
waiting, interrupt it<a name="line.678"></a>
+<span class="sourceLineNo">679</span> if (worker.isAlive()) {<a
name="line.679"></a>
+<span class="sourceLineNo">680</span> worker.interrupt();<a
name="line.680"></a>
+<span class="sourceLineNo">681</span> }<a name="line.681"></a>
+<span class="sourceLineNo">682</span> // If entry reader is alive after
waiting, interrupt it<a name="line.682"></a>
+<span class="sourceLineNo">683</span> if (worker.entryReader.isAlive())
{<a name="line.683"></a>
+<span class="sourceLineNo">684</span>
worker.entryReader.interrupt();<a name="line.684"></a>
<span class="sourceLineNo">685</span> }<a name="line.685"></a>
-<span class="sourceLineNo">686</span> // If worker still is alive after
waiting, interrupt it<a name="line.686"></a>
-<span class="sourceLineNo">687</span> if (worker.isAlive()) {<a
name="line.687"></a>
-<span class="sourceLineNo">688</span> worker.interrupt();<a
name="line.688"></a>
-<span class="sourceLineNo">689</span> }<a name="line.689"></a>
-<span class="sourceLineNo">690</span> // If entry reader is alive after
waiting, interrupt it<a name="line.690"></a>
-<span class="sourceLineNo">691</span> if (worker.entryReader.isAlive())
{<a name="line.691"></a>
-<span class="sourceLineNo">692</span>
worker.entryReader.interrupt();<a name="line.692"></a>
-<span class="sourceLineNo">693</span> }<a name="line.693"></a>
-<span class="sourceLineNo">694</span> }<a name="line.694"></a>
-<span class="sourceLineNo">695</span> if (!server.isAborted() &&
!server.isStopped()) {<a name="line.695"></a>
-<span class="sourceLineNo">696</span> // If server is running and
worker is already stopped but there was still entries batched,<a
name="line.696"></a>
-<span class="sourceLineNo">697</span> // we need to clear buffer used
for non processed entries<a name="line.697"></a>
-<span class="sourceLineNo">698</span> worker.clearWALEntryBatch();<a
name="line.698"></a>
-<span class="sourceLineNo">699</span> }<a name="line.699"></a>
-<span class="sourceLineNo">700</span> }<a name="line.700"></a>
-<span class="sourceLineNo">701</span><a name="line.701"></a>
-<span class="sourceLineNo">702</span> if (join) {<a name="line.702"></a>
-<span class="sourceLineNo">703</span> for (ReplicationSourceShipper
worker : workers) {<a name="line.703"></a>
-<span class="sourceLineNo">704</span> Threads.shutdown(worker,
this.sleepForRetries);<a name="line.704"></a>
-<span class="sourceLineNo">705</span> LOG.info("{}
ReplicationSourceWorker {} terminated", logPeerId(), worker.getName());<a
name="line.705"></a>
-<span class="sourceLineNo">706</span> }<a name="line.706"></a>
-<span class="sourceLineNo">707</span> if (this.replicationEndpoint !=
null) {<a name="line.707"></a>
-<span class="sourceLineNo">708</span> try {<a name="line.708"></a>
-<span class="sourceLineNo">709</span>
this.replicationEndpoint.awaitTerminated(sleepForRetries *
maxRetriesMultiplier,<a name="line.709"></a>
-<span class="sourceLineNo">710</span> TimeUnit.MILLISECONDS);<a
name="line.710"></a>
-<span class="sourceLineNo">711</span> } catch (TimeoutException te) {<a
name="line.711"></a>
-<span class="sourceLineNo">712</span> LOG.warn("{} Got exception
while waiting for endpoint to shutdown "<a name="line.712"></a>
-<span class="sourceLineNo">713</span> + "for replication source :
{}", logPeerId(), this.queueId, te);<a name="line.713"></a>
-<span class="sourceLineNo">714</span> }<a name="line.714"></a>
-<span class="sourceLineNo">715</span> }<a name="line.715"></a>
-<span class="sourceLineNo">716</span> }<a name="line.716"></a>
-<span class="sourceLineNo">717</span> if (clearMetrics) {<a
name="line.717"></a>
-<span class="sourceLineNo">718</span> // Can be null in test context.<a
name="line.718"></a>
-<span class="sourceLineNo">719</span> if (this.metrics != null) {<a
name="line.719"></a>
-<span class="sourceLineNo">720</span> this.metrics.clear();<a
name="line.720"></a>
-<span class="sourceLineNo">721</span> }<a name="line.721"></a>
-<span class="sourceLineNo">722</span> }<a name="line.722"></a>
-<span class="sourceLineNo">723</span> }<a name="line.723"></a>
-<span class="sourceLineNo">724</span><a name="line.724"></a>
-<span class="sourceLineNo">725</span> @Override<a name="line.725"></a>
-<span class="sourceLineNo">726</span> public String getQueueId() {<a
name="line.726"></a>
-<span class="sourceLineNo">727</span> return this.queueId;<a
name="line.727"></a>
-<span class="sourceLineNo">728</span> }<a name="line.728"></a>
-<span class="sourceLineNo">729</span><a name="line.729"></a>
-<span class="sourceLineNo">730</span> @Override<a name="line.730"></a>
-<span class="sourceLineNo">731</span> public Path getCurrentPath() {<a
name="line.731"></a>
-<span class="sourceLineNo">732</span> // only for testing<a
name="line.732"></a>
-<span class="sourceLineNo">733</span> for (ReplicationSourceShipper worker
: workerThreads.values()) {<a name="line.733"></a>
-<span class="sourceLineNo">734</span> if (worker.getCurrentPath() !=
null) {<a name="line.734"></a>
-<span class="sourceLineNo">735</span> return worker.getCurrentPath();<a
name="line.735"></a>
-<span class="sourceLineNo">736</span> }<a name="line.736"></a>
-<span class="sourceLineNo">737</span> }<a name="line.737"></a>
-<span class="sourceLineNo">738</span> return null;<a name="line.738"></a>
-<span class="sourceLineNo">739</span> }<a name="line.739"></a>
-<span class="sourceLineNo">740</span><a name="line.740"></a>
-<span class="sourceLineNo">741</span> @Override<a name="line.741"></a>
-<span class="sourceLineNo">742</span> public boolean isSourceActive() {<a
name="line.742"></a>
-<span class="sourceLineNo">743</span> return !this.server.isStopped()
&& this.sourceRunning;<a name="line.743"></a>
-<span class="sourceLineNo">744</span> }<a name="line.744"></a>
-<span class="sourceLineNo">745</span><a name="line.745"></a>
-<span class="sourceLineNo">746</span> public ReplicationQueueInfo
getReplicationQueueInfo() {<a name="line.746"></a>
-<span class="sourceLineNo">747</span> return replicationQueueInfo;<a
name="line.747"></a>
-<span class="sourceLineNo">748</span> }<a name="line.748"></a>
-<span class="sourceLineNo">749</span><a name="line.749"></a>
-<span class="sourceLineNo">750</span> public boolean isWorkerRunning() {<a
name="line.750"></a>
-<span class="sourceLineNo">751</span> for (ReplicationSourceShipper worker
: this.workerThreads.values()) {<a name="line.751"></a>
-<span class="sourceLineNo">752</span> if (worker.isActive()) {<a
name="line.752"></a>
-<span class="sourceLineNo">753</span> return worker.isActive();<a
name="line.753"></a>
-<span class="sourceLineNo">754</span> }<a name="line.754"></a>
-<span class="sourceLineNo">755</span> }<a name="line.755"></a>
-<span class="sourceLineNo">756</span> return false;<a name="line.756"></a>
-<span class="sourceLineNo">757</span> }<a name="line.757"></a>
-<span class="sourceLineNo">758</span><a name="line.758"></a>
-<span class="sourceLineNo">759</span> @Override<a name="line.759"></a>
-<span class="sourceLineNo">760</span> public String getStats() {<a
name="line.760"></a>
-<span class="sourceLineNo">761</span> StringBuilder sb = new
StringBuilder();<a name="line.761"></a>
-<span class="sourceLineNo">762</span> sb.append("Total replicated edits:
").append(totalReplicatedEdits)<a name="line.762"></a>
-<span class="sourceLineNo">763</span> .append(", current progress:
\n");<a name="line.763"></a>
-<span class="sourceLineNo">764</span> for (Map.Entry<String,
ReplicationSourceShipper> entry : workerThreads.entrySet()) {<a
name="line.764"></a>
-<span class="sourceLineNo">765</span> String walGroupId =
entry.getKey();<a name="line.765"></a>
-<span class="sourceLineNo">766</span> ReplicationSourceShipper worker =
entry.getValue();<a name="line.766"></a>
-<span class="sourceLineNo">767</span> long position =
worker.getCurrentPosition();<a name="line.767"></a>
-<span class="sourceLineNo">768</span> Path currentPath =
worker.getCurrentPath();<a name="line.768"></a>
-<span class="sourceLineNo">769</span> sb.append("walGroup
[").append(walGroupId).append("]: ");<a name="line.769"></a>
-<span class="sourceLineNo">770</span> if (currentPath != null) {<a
name="line.770"></a>
-<span class="sourceLineNo">771</span> sb.append("currently replicating
from: ").append(currentPath).append(" at position: ")<a name="line.771"></a>
-<span class="sourceLineNo">772</span>
.append(position).append("\n");<a name="line.772"></a>
-<span class="sourceLineNo">773</span> } else {<a name="line.773"></a>
-<span class="sourceLineNo">774</span> sb.append("no replication
ongoing, waiting for new log");<a name="line.774"></a>
-<span class="sourceLineNo">775</span> }<a name="line.775"></a>
-<span class="sourceLineNo">776</span> }<a name="line.776"></a>
-<span class="sourceLineNo">777</span> return sb.toString();<a
name="line.777"></a>
-<span class="sourceLineNo">778</span> }<a name="line.778"></a>
-<span class="sourceLineNo">779</span><a name="line.779"></a>
-<span class="sourceLineNo">780</span> @Override<a name="line.780"></a>
-<span class="sourceLineNo">781</span> public MetricsSource getSourceMetrics()
{<a name="line.781"></a>
-<span class="sourceLineNo">782</span> return this.metrics;<a
name="line.782"></a>
-<span class="sourceLineNo">783</span> }<a name="line.783"></a>
-<span class="sourceLineNo">784</span><a name="line.784"></a>
-<span class="sourceLineNo">785</span> @Override<a name="line.785"></a>
-<span class="sourceLineNo">786</span> // offsets totalBufferUsed by deducting
shipped batchSize.<a name="line.786"></a>
-<span class="sourceLineNo">787</span> public void
postShipEdits(List<Entry> entries, int batchSize) {<a name="line.787"></a>
-<span class="sourceLineNo">788</span> if (throttler.isEnabled()) {<a
name="line.788"></a>
-<span class="sourceLineNo">789</span> throttler.addPushSize(batchSize);<a
name="line.789"></a>
-<span class="sourceLineNo">790</span> }<a name="line.790"></a>
-<span class="sourceLineNo">791</span>
totalReplicatedEdits.addAndGet(entries.size());<a name="line.791"></a>
-<span class="sourceLineNo">792</span> long newBufferUsed =
totalBufferUsed.addAndGet(-batchSize);<a name="line.792"></a>
-<span class="sourceLineNo">793</span> // Record the new buffer usage<a
name="line.793"></a>
-<span class="sourceLineNo">794</span>
this.manager.getGlobalMetrics().setWALReaderEditsBufferBytes(newBufferUsed);<a
name="line.794"></a>
-<span class="sourceLineNo">795</span> }<a name="line.795"></a>
-<span class="sourceLineNo">796</span><a name="line.796"></a>
-<span class="sourceLineNo">797</span> @Override<a name="line.797"></a>
-<span class="sourceLineNo">798</span> public WALFileLengthProvider
getWALFileLengthProvider() {<a name="line.798"></a>
-<span class="sourceLineNo">799</span> return walFileLengthProvider;<a
name="line.799"></a>
-<span class="sourceLineNo">800</span> }<a name="line.800"></a>
-<span class="sourceLineNo">801</span><a name="line.801"></a>
-<span class="sourceLineNo">802</span> @Override<a name="line.802"></a>
-<span class="sourceLineNo">803</span> public ServerName
getServerWALsBelongTo() {<a name="line.803"></a>
-<span class="sourceLineNo">804</span> return server.getServerName();<a
name="line.804"></a>
-<span class="sourceLineNo">805</span> }<a name="line.805"></a>
-<span class="sourceLineNo">806</span><a name="line.806"></a>
-<span class="sourceLineNo">807</span> @Override<a name="line.807"></a>
-<span class="sourceLineNo">808</span> public ReplicationPeer getPeer() {<a
name="line.808"></a>
-<span class="sourceLineNo">809</span> return replicationPeer;<a
name="line.809"></a>
-<span class="sourceLineNo">810</span> }<a name="line.810"></a>
-<span class="sourceLineNo">811</span><a name="line.811"></a>
-<span class="sourceLineNo">812</span> Server getServer() {<a
name="line.812"></a>
-<span class="sourceLineNo">813</span> return server;<a name="line.813"></a>
-<span class="sourceLineNo">814</span> }<a name="line.814"></a>
-<span class="sourceLineNo">815</span><a name="line.815"></a>
-<span class="sourceLineNo">816</span> @Override<a name="line.816"></a>
-<span class="sourceLineNo">817</span> public ReplicationQueueStorage
getReplicationQueueStorage() {<a name="line.817"></a>
-<span class="sourceLineNo">818</span> return queueStorage;<a
name="line.818"></a>
+<span class="sourceLineNo">686</span> }<a name="line.686"></a>
+<span class="sourceLineNo">687</span> if (!server.isAborted() &&
!server.isStopped()) {<a name="line.687"></a>
+<span class="sourceLineNo">688</span> // If server is running and
worker is already stopped but there was still entries batched,<a
name="line.688"></a>
+<span class="sourceLineNo">689</span> // we need to clear buffer used
for non processed entries<a name="line.689"></a>
+<span class="sourceLineNo">690</span> worker.clearWALEntryBatch();<a
name="line.690"></a>
+<span class="sourceLineNo">691</span> }<a name="line.691"></a>
+<span class="sourceLineNo">692</span> }<a name="line.692"></a>
+<span class="sourceLineNo">693</span><a name="line.693"></a>
+<span class="sourceLineNo">694</span> if (join) {<a name="line.694"></a>
+<span class="sourceLineNo">695</span> for (ReplicationSourceShipper
worker : workers) {<a name="line.695"></a>
+<span class="sourceLineNo">696</span> Threads.shutdown(worker,
this.sleepForRetries);<a name="line.696"></a>
+<span class="sourceLineNo">697</span> LOG.info("{}
ReplicationSourceWorker {} terminated", logPeerId(), worker.getName());<a
name="line.697"></a>
+<span class="sourceLineNo">698</span> }<a name="line.698"></a>
+<span class="sourceLineNo">699</span> if (this.replicationEndpoint !=
null) {<a name="line.699"></a>
+<span class="sourceLineNo">700</span> try {<a name="line.700"></a>
+<span class="sourceLineNo">701</span>
this.replicationEndpoint.awaitTerminated(sleepForRetries *
maxRetriesMultiplier,<a name="line.701"></a>
+<span class="sourceLineNo">702</span> TimeUnit.MILLISECONDS);<a
name="line.702"></a>
+<span class="sourceLineNo">703</span> } catch (TimeoutException te) {<a
name="line.703"></a>
+<span class="sourceLineNo">704</span> LOG.warn("{} Got exception
while waiting for endpoint to shutdown "<a name="line.704"></a>
+<span class="sourceLineNo">705</span> + "for replication source :
{}", logPeerId(), this.queueId, te);<a name="line.705"></a>
+<span class="sourceLineNo">706</span> }<a name="line.706"></a>
+<span class="sourceLineNo">707</span> }<a name="line.707"></a>
+<span class="sourceLineNo">708</span> }<a name="line.708"></a>
+<span class="sourceLineNo">709</span> if (clearMetrics) {<a
name="line.709"></a>
+<span class="sourceLineNo">710</span> // Can be null in test context.<a
name="line.710"></a>
+<span class="sourceLineNo">711</span> if (this.metrics != null) {<a
name="line.711"></a>
+<span class="sourceLineNo">712</span> this.metrics.clear();<a
name="line.712"></a>
+<span class="sourceLineNo">713</span> }<a name="line.713"></a>
+<span class="sourceLineNo">714</span> }<a name="line.714"></a>
+<span class="sourceLineNo">715</span> }<a name="line.715"></a>
+<span class="sourceLineNo">716</span><a name="line.716"></a>
+<span class="sourceLineNo">717</span> @Override<a name="line.717"></a>
+<span class="sourceLineNo">718</span> public String getQueueId() {<a
name="line.718"></a>
+<span class="sourceLineNo">719</span> return this.queueId;<a
name="line.719"></a>
+<span class="sourceLineNo">720</span> }<a name="line.720"></a>
+<span class="sourceLineNo">721</span><a name="line.721"></a>
+<span class="sourceLineNo">722</span> @Override<a name="line.722"></a>
+<span class="sourceLineNo">723</span> public Path getCurrentPath() {<a
name="line.723"></a>
+<span class="sourceLineNo">724</span> // only for testing<a
name="line.724"></a>
+<span class="sourceLineNo">725</span> for (ReplicationSourceShipper worker
: workerThreads.values()) {<a name="line.725"></a>
+<span class="sourceLineNo">726</span> if (worker.getCurrentPath() !=
null) {<a name="line.726"></a>
+<span class="sourceLineNo">727</span> return worker.getCurrentPath();<a
name="line.727"></a>
+<span class="sourceLineNo">728</span> }<a name="line.728"></a>
+<span class="sourceLineNo">729</span> }<a name="line.729"></a>
+<span class="sourceLineNo">730</span> return null;<a name="line.730"></a>
+<span class="sourceLineNo">731</span> }<a name="line.731"></a>
+<span class="sourceLineNo">732</span><a name="line.732"></a>
+<span class="sourceLineNo">733</span> @Override<a name="line.733"></a>
+<span class="sourceLineNo">734</span> public boolean isSourceActive() {<a
name="line.734"></a>
+<span class="sourceLineNo">735</span> return !this.server.isStopped()
&& this.sourceRunning;<a name="line.735"></a>
+<span class="sourceLineNo">736</span> }<a name="line.736"></a>
+<span class="sourceLineNo">737</span><a name="line.737"></a>
+<span class="sourceLineNo">738</span> public ReplicationQueueInfo
getReplicationQueueInfo() {<a name="line.738"></a>
+<span class="sourceLineNo">739</span> return replicationQueueInfo;<a
name="line.739"></a>
+<span class="sourceLineNo">740</span> }<a name="line.740"></a>
+<span class="sourceLineNo">741</span><a name="line.741"></a>
+<span class="sourceLineNo">742</span> public boolean isWorkerRunning() {<a
name="line.742"></a>
+<span class="sourceLineNo">743</span> for (ReplicationSourceShipper worker
: this.workerThreads.values()) {<a name="line.743"></a>
+<span class="sourceLineNo">744</span> if (worker.isActive()) {<a
name="line.744"></a>
+<span class="sourceLineNo">745</span> return worker.isActive();<a
name="line.745"></a>
+<span class="sourceLineNo">746</span> }<a name="line.746"></a>
+<span class="sourceLineNo">747</span> }<a name="line.747"></a>
+<span class="sourceLineNo">748</span> return false;<a name="line.748"></a>
+<span class="sourceLineNo">749</span> }<a name="line.749"></a>
+<span class="sourceLineNo">750</span><a name="line.750"></a>
+<span class="sourceLineNo">751</span> @Override<a name="line.751"></a>
+<span class="sourceLineNo">752</span> public String getStats() {<a
name="line.752"></a>
+<span class="sourceLineNo">753</span> StringBuilder sb = new
StringBuilder();<a name="line.753"></a>
+<span class="sourceLineNo">754</span> sb.append("Total replicated edits:
").append(totalReplicatedEdits)<a name="line.754"></a>
+<span class="sourceLineNo">755</span> .append(", current progress:
\n");<a name="line.755"></a>
+<span class="sourceLineNo">756</span> for (Map.Entry<String,
ReplicationSourceShipper> entry : workerThreads.entrySet()) {<a
name="line.756"></a>
+<span class="sourceLineNo">757</span> String walGroupId =
entry.getKey();<a name="line.757"></a>
+<span class="sourceLineNo">758</span> ReplicationSourceShipper worker =
entry.getValue();<a name="line.758"></a>
+<span class="sourceLineNo">759</span> long position =
worker.getCurrentPosition();<a name="line.759"></a>
+<span class="sourceLineNo">760</span> Path currentPath =
worker.getCurrentPath();<a name="line.760"></a>
+<span class="sourceLineNo">761</span> sb.append("walGroup
[").append(walGroupId).append("]: ");<a name="line.761"></a>
+<span class="sourceLineNo">762</span> if (currentPath != null) {<a
name="line.762"></a>
+<span class="sourceLineNo">763</span> sb.append("currently replicating
from: ").append(currentPath).append(" at position: ")<a name="line.763"></a>
+<span class="sourceLineNo">764</span>
.append(position).append("\n");<a name="line.764"></a>
+<span class="sourceLineNo">765</span> } else {<a name="line.765"></a>
+<span class="sourceLineNo">766</span> sb.append("no replication
ongoing, waiting for new log");<a name="line.766"></a>
+<span class="sourceLineNo">767</span> }<a name="line.767"></a>
+<span class="sourceLineNo">768</span> }<a name="line.768"></a>
+<span class="sourceLineNo">769</span> return sb.toString();<a
name="line.769"></a>
+<span class="sourceLineNo">770</span> }<a name="line.770"></a>
+<span class="sourceLineNo">771</span><a name="line.771"></a>
+<span class="sourceLineNo">772</span> @Override<a name="line.772"></a>
+<span class="sourceLineNo">773</span> public MetricsSource getSourceMetrics()
{<a name="line.773"></a>
+<span class="sourceLineNo">774</span> return this.metrics;<a
name="line.774"></a>
+<span class="sourceLineNo">775</span> }<a name="line.775"></a>
+<span class="sourceLineNo">776</span><a name="line.776"></a>
+<span class="sourceLineNo">777</span> @Override<a name="line.777"></a>
+<span class="sourceLineNo">778</span> // offsets totalBufferUsed by deducting
shipped batchSize.<a name="line.778"></a>
+<span class="sourceLineNo">779</span> public void
postShipEdits(List<Entry> entries, int batchSize) {<a name="line.779"></a>
+<span class="sourceLineNo">780</span> if (throttler.isEnabled()) {<a
name="line.780"></a>
+<span class="sourceLineNo">781</span> throttler.addPushSize(batchSize);<a
name="line.781"></a>
+<span class="sourceLineNo">782</span> }<a name="line.782"></a>
+<span class="sourceLineNo">783</span>
totalReplicatedEdits.addAndGet(entries.size());<a name="line.783"></a>
+<span class="sourceLineNo">784</span> long newBufferUsed =
totalBufferUsed.addAndGet(-batchSize);<a name="line.784"></a>
+<span class="sourceLineNo">785</span> // Record the new buffer usage<a
name="line.785"></a>
+<span class="sourceLineNo">786</span>
this.manager.getGlobalMetrics().setWALReaderEditsBufferBytes(newBufferUsed);<a
name="line.786"></a>
+<span class="sourceLineNo">787</span> }<a name="line.787"></a>
+<span class="sourceLineNo">788</span><a name="line.788"></a>
+<span class="sourceLineNo">789</span> @Override<a name="line.789"></a>
+<span class="sourceLineNo">790</span> public WALFileLengthProvider
getWALFileLengthProvider() {<a name="line.790"></a>
+<span class="sourceLineNo">791</span> return walFileLengthProvider;<a
name="line.791"></a>
+<span class="sourceLineNo">792</span> }<a name="line.792"></a>
+<span class="sourceLineNo">793</span><a name="line.793"></a>
+<span class="sourceLineNo">794</span> @Override<a name="line.794"></a>
+<span class="sourceLineNo">795</span> public ServerName
getServerWALsBelongTo() {<a name="line.795"></a>
+<span class="sourceLineNo">796</span> return server.getServerName();<a
name="line.796"></a>
+<span class="sourceLineNo">797</span> }<a name="line.797"></a>
+<span class="sourceLineNo">798</span><a name="line.798"></a>
+<span class="sourceLineNo">799</span> @Override<a name="line.799"></a>
+<span class="sourceLineNo">800</span> public ReplicationPeer getPeer() {<a
name="line.800"></a>
+<span class="sourceLineNo">801</span> return replicationPeer;<a
name="line.801"></a>
+<span class="sourceLineNo">802</span> }<a name="line.802"></a>
+<span class="sourceLineNo">803</span><a name="line.803"></a>
+<span class="sourceLineNo">804</span> Server getServer() {<a
name="line.804"></a>
+<span class="sourceLineNo">805</span> return server;<a name="line.805"></a>
+<span class="sourceLineNo">806</span> }<a name="line.806"></a>
+<span class="sourceLineNo">807</span><a name="line.807"></a>
+<span class="sourceLineNo">808</span> @Override<a name="line.808"></a>
+<span class="sourceLineNo">809</span> public ReplicationQueueStorage
getReplicationQueueStorage() {<a name="line.809"></a>
+<span class="sourceLineNo">810</span> return queueStorage;<a
name="line.810"></a>
+<span class="sourceLineNo">811</span> }<a name="line.811"></a>
+<span class="sourceLineNo">812</span><a name="line.812"></a>
+<span class="sourceLineNo">813</span> void
removeWorker(ReplicationSourceShipper worker) {<a name="line.813"></a>
+<span class="sourceLineNo">814</span>
workerThreads.remove(worker.walGroupId, worker);<a name="line.814"></a>
+<span class="sourceLineNo">815</span> }<a name="line.815"></a>
+<span class="sourceLineNo">816</span><a name="line.816"></a>
+<span class="sourceLineNo">817</span> public String logPeerId() {<a
name="line.817"></a>
+<span class="sourceLineNo">818</span> return "peerId=" + this.getPeerId() +
",";<a name="line.818"></a>
<span class="sourceLineNo">819</span> }<a name="line.819"></a>
-<span class="sourceLineNo">820</span><a name="line.820"></a>
-<span class="sourceLineNo">821</span> void
removeWorker(ReplicationSourceShipper worker) {<a name="line.821"></a>
-<span class="sourceLineNo">822</span>
workerThreads.remove(worker.walGroupId, worker);<a name="line.822"></a>
-<span class="sourceLineNo">823</span> }<a name="line.823"></a>
-<span class="sourceLineNo">824</span><a name="line.824"></a>
-<span class="sourceLineNo">825</span> public String logPeerId() {<a
name="line.825"></a>
-<span class="sourceLineNo">826</span> return "peerId=" + this.getPeerId() +
",";<a name="line.826"></a>
-<span class="sourceLineNo">827</span> }<a name="line.827"></a>
-<span class="sourceLineNo">828</span>}<a name="line.828"></a>
+<span class="sourceLineNo">820</span>}<a name="line.820"></a>
diff --git a/downloads.html b/downloads.html
index d0888061a7b..f376002b6c0 100644
--- a/downloads.html
+++ b/downloads.html
@@ -443,7 +443,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/export_control.html b/export_control.html
index 6fdd8f5a88e..27f05eccd13 100644
--- a/export_control.html
+++ b/export_control.html
@@ -205,7 +205,7 @@ for more details.</p>
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/index.html b/index.html
index c1fa8f3fe42..f8e042eca67 100644
--- a/index.html
+++ b/index.html
@@ -278,7 +278,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/issue-management.html b/issue-management.html
index 5b29f48b1e0..3de06492c6b 100644
--- a/issue-management.html
+++ b/issue-management.html
@@ -176,7 +176,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/licenses.html b/licenses.html
index 73a83d04057..d5cc8167dae 100644
--- a/licenses.html
+++ b/licenses.html
@@ -378,7 +378,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/mailing-lists.html b/mailing-lists.html
index cc156d8e989..c1d05ec3f94 100644
--- a/mailing-lists.html
+++ b/mailing-lists.html
@@ -223,7 +223,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/metrics.html b/metrics.html
index e0355e7cce6..10b897962e1 100644
--- a/metrics.html
+++ b/metrics.html
@@ -327,7 +327,7 @@ export HBASE_REGIONSERVER_OPTS="$HBASE_JMX_OPTS
-Dcom.sun.management.jmxrem
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/old_news.html b/old_news.html
index 31df1ef934a..4783d92dc98 100644
--- a/old_news.html
+++ b/old_news.html
@@ -324,7 +324,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/plugin-management.html b/plugin-management.html
index cc11a22258a..b644d0550d7 100644
--- a/plugin-management.html
+++ b/plugin-management.html
@@ -172,7 +172,7 @@
<tr class="b">
<td align="left">com.github.spotbugs</td>
<td><a class="externalLink"
href="https://spotbugs.github.io/spotbugs-maven-plugin/";>spotbugs-maven-plugin</a></td>
-<td>4.2.0</td></tr>
+<td>4.7.2.0</td></tr>
<tr class="a">
<td align="left">net.revelc.code</td>
<td><a class="externalLink"
href="http://code.revelc.net/warbucks-maven-plugin";>warbucks-maven-plugin</a></td>
@@ -329,7 +329,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/plugins.html b/plugins.html
index 5daa2ec5fe0..2380ceea703 100644
--- a/plugins.html
+++ b/plugins.html
@@ -176,7 +176,7 @@
<tr class="a">
<td align="left">com.github.spotbugs</td>
<td><a class="externalLink"
href="https://spotbugs.github.io/spotbugs-maven-plugin/";>spotbugs-maven-plugin</a></td>
-<td>4.2.0</td></tr>
+<td>4.7.2.0</td></tr>
<tr class="b">
<td align="left">org.apache.felix</td>
<td><a class="externalLink"
href="http://felix.apache.org/maven-bundle-plugin/";>maven-bundle-plugin</a></td>
@@ -263,7 +263,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/poweredbyhbase.html b/poweredbyhbase.html
index 52e1ec713c4..9c0c2e3a0ab 100644
--- a/poweredbyhbase.html
+++ b/poweredbyhbase.html
@@ -658,7 +658,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/project-info.html b/project-info.html
index d9b8768e41a..37a8659d09f 100644
--- a/project-info.html
+++ b/project-info.html
@@ -220,7 +220,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/project-reports.html b/project-reports.html
index 968f38e997e..121133ed315 100644
--- a/project-reports.html
+++ b/project-reports.html
@@ -193,7 +193,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/pseudo-distributed.html b/pseudo-distributed.html
index 1ab44f246e7..b99bd8aef77 100644
--- a/pseudo-distributed.html
+++ b/pseudo-distributed.html
@@ -182,7 +182,7 @@ Running Apache HBase (TM) in pseudo-distributed mode
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/replication.html b/replication.html
index 944c53f483c..1a4031384e2 100644
--- a/replication.html
+++ b/replication.html
@@ -177,7 +177,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/resources.html b/resources.html
index 04799f64f65..05dd029d4ff 100644
--- a/resources.html
+++ b/resources.html
@@ -200,7 +200,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/scm.html b/scm.html
index 9b69c4ca6e6..5e17b23745d 100644
--- a/scm.html
+++ b/scm.html
@@ -184,7 +184,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/sponsors.html b/sponsors.html
index 9cc9a60e129..d4d49c50a8a 100644
--- a/sponsors.html
+++ b/sponsors.html
@@ -206,7 +206,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/summary.html b/summary.html
index b27679f2ca0..893d8890a40 100644
--- a/summary.html
+++ b/summary.html
@@ -217,7 +217,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/supportingprojects.html b/supportingprojects.html
index 06bc30bae7e..e57d2693b68 100644
--- a/supportingprojects.html
+++ b/supportingprojects.html
@@ -396,7 +396,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
diff --git a/team.html b/team.html
index e00dcc6eeaf..25a931c9cdd 100644
--- a/team.html
+++ b/team.html
@@ -773,7 +773,7 @@
<div class="row">
<p>Copyright ©2007–2022
<a href="https://www.apache.org/";>The Apache Software Foundation</a>.
-All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-14</li>
+All rights reserved. <li id="publishDate" class="pull-right">Last
Published: 2022-09-15</li>
</p>
</div>
<p id="poweredBy" class="pull-right"><a
href="http://maven.apache.org/"; title="Built by Maven" class="poweredBy"><img
class="builtBy" alt="Built by Maven" src="./images/logos/maven-feather.png"
/></a>
