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:56 UTC
[hbase] branch master updated: 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 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 94f36fd Amend HBASE-24350: Extending and Fixing HBaseTable level replication metrics (#1704)
94f36fd is described below
commit 94f36fdb8ecef55448eab590dee9670ab8980bd1
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 ad76c5c..e50005a 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
@@ -221,7 +221,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;
}