You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2020/05/14 20:46:55 UTC
[hbase] 02/02: Amend HBASE-24350: Extending and Fixing HBaseTable
level replication metrics (#1704)
This is an automated email from the ASF dual-hosted git repository.
apurtell pushed a commit to branch branch-2
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit a93d94cad312d7c92b3a2eb43848058605d27dcb
Author: Andrew Purtell <ap...@apache.org>
AuthorDate: Thu May 14 13:41:56 2020 -0700
Amend HBASE-24350: Extending and Fixing HBaseTable level replication metrics (#1704)
- Rename WALEntryBatch#getWaEntriesWithSize -> getWalEntriesWithSize
---
.../hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java | 2 +-
.../org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java
index 65430b3..d7e7e01 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java
@@ -211,7 +211,7 @@ public class ReplicationSourceShipper extends Thread {
entryBatch.getNbHFiles());
source.getSourceMetrics().setAgeOfLastShippedOp(
entries.get(entries.size() - 1).getKey().getWriteTime(), walGroupId);
- source.getSourceMetrics().updateTableLevelMetrics(entryBatch.getWaEntriesWithSize());
+ source.getSourceMetrics().updateTableLevelMetrics(entryBatch.getWalEntriesWithSize());
if (LOG.isTraceEnabled()) {
LOG.debug("Replicated {} entries or {} operations in {} ms",
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.java
index bc600d0..4f96c96 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.java
@@ -83,7 +83,7 @@ class WALEntryBatch {
/**
* @return the WAL Entries.
*/
- public List<Pair<Entry, Long>> getWaEntriesWithSize() {
+ public List<Pair<Entry, Long>> getWalEntriesWithSize() {
return walEntriesWithSize;
}