HBASE-27079 Lower some DEBUG level logs in ReplicationSourceWALReader…

… to TRACE (apache#4476) Signed-off-by: Viraj Jasani <[email protected]> Change-Id: Ifee163a727472b77426461090ec6591fdf7222ba
vinayakphegde · Jun 28, 2022 · ef208ac · ef208ac
1 parent 6496575
commit ef208ac
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ain/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java b/...ain/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.java
@@ -173,10 +173,10 @@ public void run() {
   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 @@ private WALEntryBatch createBatch(WALEntryStream entryStream) {
   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;