This is an automated email from the ASF dual-hosted git repository. apurtell pushed a commit to branch branch-2.5 in repository https://gitbox.apache.org/repos/asf/hbase.git
commit 2f63d99c484b2df5dfcc5f52c9faa04360d27c10 Author: Andrew Purtell <[email protected]> AuthorDate: Tue May 31 12:43:04 2022 -0700 HBASE-27079 Lower some DEBUG level logs in ReplicationSourceWALReader to TRACE (#4476) Signed-off-by: Viraj Jasani <[email protected]> --- .../hbase/replication/regionserver/ReplicationSourceWALReader.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java index d95e21241e..ef550fe697 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java @@ -173,10 +173,10 @@ class ReplicationSourceWALReader extends Thread { protected final boolean addEntryToBatch(WALEntryBatch batch, Entry entry) { WALEdit edit = entry.getEdit(); if (edit == null || edit.isEmpty()) { - LOG.debug("Edit null or empty for entry {} ", entry); + LOG.trace("Edit null or empty for entry {} ", entry); return false; } - LOG.debug("updating TimeStampOfLastAttempted to {}, from entry {}, for source queue: {}", + LOG.trace("updating TimeStampOfLastAttempted to {}, from entry {}, for source queue: {}", entry.getKey().getWriteTime(), entry.getKey(), this.source.getQueueId()); long entrySize = getEntrySizeIncludeBulkLoad(entry); long entrySizeExcludeBulkLoad = getEntrySizeExcludeBulkLoad(entry); @@ -343,7 +343,7 @@ class ReplicationSourceWALReader extends Thread { protected final Entry filterEntry(Entry entry) { Entry filtered = filter.filter(entry); if (entry != null && (filtered == null || filtered.getEdit().size() == 0)) { - LOG.debug("Filtered entry for replication: {}", entry); + LOG.trace("Filtered entry for replication: {}", entry); source.getSourceMetrics().incrLogEditsFiltered(); } return filtered;
