You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2019/10/31 01:24:12 UTC
[hbase] branch master updated: HBASE-23231 ReplicationSource do not
update metrics after refresh (#778)
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/master by this push:
new 3152d99 HBASE-23231 ReplicationSource do not update metrics after refresh (#778)
3152d99 is described below
commit 3152d9981b8d99ba8a7b72672275baab5faa52e7
Author: binlijin <bi...@gmail.com>
AuthorDate: Thu Oct 31 09:23:59 2019 +0800
HBASE-23231 ReplicationSource do not update metrics after refresh (#778)
Signed-off-by: stack <st...@apache.org>
Signed-off-by: Duo Zhang <zh...@apache.org>
---
.../hbase/replication/regionserver/ReplicationSource.java | 15 ++++++++++++---
.../regionserver/ReplicationSourceInterface.java | 8 ++++++++
.../regionserver/ReplicationSourceManager.java | 3 ++-
.../hadoop/hbase/replication/ReplicationSourceDummy.java | 9 ++++++++-
4 files changed, 30 insertions(+), 5 deletions(-)
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
index 948c24d..78edffa 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
@@ -549,7 +549,12 @@ public class ReplicationSource implements ReplicationSourceInterface {
terminate(reason, cause, true);
}
- public void terminate(String reason, Exception cause, boolean join) {
+ @Override
+ public void terminate(String reason, Exception cause, boolean clearMetrics) {
+ terminate(reason, cause, clearMetrics, true);
+ }
+
+ public void terminate(String reason, Exception cause, boolean clearMetrics, boolean join) {
if (cause == null) {
LOG.info("{} Closing source {} because: {}", logPeerId(), this.queueId, reason);
} else {
@@ -595,7 +600,9 @@ public class ReplicationSource implements ReplicationSourceInterface {
if (this.replicationEndpoint != null) {
this.replicationEndpoint.stop();
}
- metrics.clear();
+ if (clearMetrics) {
+ metrics.clear();
+ }
if (join) {
for (ReplicationSourceShipper worker : workers) {
Threads.shutdown(worker, this.sleepForRetries);
@@ -611,7 +618,9 @@ public class ReplicationSource implements ReplicationSourceInterface {
}
}
}
- this.metrics.clear();
+ if (clearMetrics) {
+ this.metrics.clear();
+ }
}
@Override
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.java
index df7a8cc..0bd90cf 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.java
@@ -92,6 +92,14 @@ public interface ReplicationSourceInterface {
void terminate(String reason, Exception cause);
/**
+ * End the replication
+ * @param reason why it's terminating
+ * @param cause the error that's causing it
+ * @param clearMetrics removes all metrics about this Source
+ */
+ void terminate(String reason, Exception cause, boolean clearMetrics);
+
+ /**
* Get the current log that's replicated
* @return the current log
*/
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java
index de37cc8..43afa79 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java
@@ -482,7 +482,8 @@ public class ReplicationSourceManager implements ReplicationListener {
ReplicationSourceInterface toRemove = this.sources.put(peerId, src);
if (toRemove != null) {
LOG.info("Terminate replication source for " + toRemove.getPeerId());
- toRemove.terminate(terminateMessage);
+ // Do not clear metrics
+ toRemove.terminate(terminateMessage, null, false);
}
for (NavigableSet<String> walsByGroup : walsById.get(peerId).values()) {
walsByGroup.forEach(wal -> src.enqueueLog(new Path(this.logDir, wal)));
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/ReplicationSourceDummy.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/ReplicationSourceDummy.java
index 67f793d..a361c44 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/ReplicationSourceDummy.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/ReplicationSourceDummy.java
@@ -86,7 +86,14 @@ public class ReplicationSourceDummy implements ReplicationSourceInterface {
@Override
public void terminate(String reason, Exception e) {
- this.metrics.clear();
+ terminate(reason, e, true);
+ }
+
+ @Override
+ public void terminate(String reason, Exception e, boolean clearMetrics) {
+ if (clearMetrics) {
+ this.metrics.clear();
+ }
}
@Override