HDFS-13789. Reduce logging frequency of QuorumJournalManager#selectInputStreams. Contributed by Erik Krogen.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/4c9baba0 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/4c9baba0 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/4c9baba0 Branch: refs/heads/trunk Commit: 4c9baba06629e3b3f8eddc52afb62c5fbcb06178 Parents: eae0a5d Author: Chao Sun <[email protected]> Authored: Wed Aug 8 13:09:39 2018 -0700 Committer: Konstantin V Shvachko <[email protected]> Committed: Mon Dec 24 09:34:00 2018 -0800 ---------------------------------------------------------------------- .../hadoop/hdfs/qjournal/client/QuorumJournalManager.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/4c9baba0/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/QuorumJournalManager.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/QuorumJournalManager.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/QuorumJournalManager.java index 26590d5..f96fe09 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/QuorumJournalManager.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/QuorumJournalManager.java @@ -498,8 +498,10 @@ public class QuorumJournalManager implements JournalManager { // the cache used for RPC calls is not enabled; fall back to using the // streaming mechanism to serve such requests if (inProgressOk && inProgressTailingEnabled) { - LOG.info("Tailing edits starting from txn ID " + fromTxnId + - " via RPC mechanism"); + if (LOG.isDebugEnabled()) { + LOG.debug("Tailing edits starting from txn ID " + fromTxnId + + " via RPC mechanism"); + } try { Collection<EditLogInputStream> rpcStreams = new ArrayList<>(); selectRpcInputStreams(rpcStreams, fromTxnId, onlyDurableTxns); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
