From 94f36fdb8ecef55448eab590dee9670ab8980bd1 Mon Sep 17 00:00:00 2001 From: Andrew Purtell Date: Thu, 14 May 2020 13:41:56 -0700 Subject: [PATCH] Amend HBASE-24350: Extending and Fixing HBaseTable level replication metrics (#1704) - Rename WALEntryBatch#getWaEntriesWithSize -> getWalEntriesWithSize --- .../replication/regionserver/ReplicationSourceShipper.java | 2 +- .../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 ad76c5c4616..e50005a2339 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 bc600d08880..4f96c96d3c5 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> getWaEntriesWithSize() { + public List> getWalEntriesWithSize() { return walEntriesWithSize; }