Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-27079 Lower some DEBUG level logs in ReplicationSourceWALReader to TRACE (#4476) 

Signed-off-by: Viraj Jasani <vjasani@apache.org>
This commit is contained in:
Andrew Purtell 2022-05-31 12:43:04 -07:00
parent f4f3e63f9f
commit 59700babd0
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java
View File

@ -173,10 +173,10 @@ class ReplicationSourceWALReader extends Thread {
protected final boolean addEntryToBatch(WALEntryBatch batch, Entry entry) { protected final boolean addEntryToBatch(WALEntryBatch batch, Entry entry) {
WALEdit edit = entry.getEdit(); WALEdit edit = entry.getEdit();
if (edit == null || edit.isEmpty()) { 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; 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()); entry.getKey().getWriteTime(), entry.getKey(), this.source.getQueueId());
long entrySize = getEntrySizeIncludeBulkLoad(entry); long entrySize = getEntrySizeIncludeBulkLoad(entry);
long entrySizeExcludeBulkLoad = getEntrySizeExcludeBulkLoad(entry); long entrySizeExcludeBulkLoad = getEntrySizeExcludeBulkLoad(entry);
@ -343,7 +343,7 @@ class ReplicationSourceWALReader extends Thread {
protected final Entry filterEntry(Entry entry) { protected final Entry filterEntry(Entry entry) {
Entry filtered = filter.filter(entry); Entry filtered = filter.filter(entry);
if (entry != null && (filtered == null || filtered.getEdit().size() == 0)) { 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(); source.getSourceMetrics().incrLogEditsFiltered();
} }
return filtered; return filtered;