This is an automated email from the ASF dual-hosted git repository.
apurtell pushed a commit to branch branch-2.4
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.4 by this push:
new f1c7f3a2f0 HBASE-27079 Lower some DEBUG level logs in
ReplicationSourceWALReader to TRACE (#4476)
f1c7f3a2f0 is described below
commit f1c7f3a2f0ce8a0e2b5e8e4ece417132e3bc80e6
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;