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

HDFS-13789. Reduce logging frequency of QuorumJournalManager#selectInputStreams. Contributed by Erik Krogen.

This commit is contained in:
Chao Sun 2018-08-08 13:09:39 -07:00 committed by Chen Liang
parent e3f3fb1c18
commit 6fe755f0c7
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/client/QuorumJournalManager.java
View File

@ -499,8 +499,10 @@ public class QuorumJournalManager implements JournalManager {
// the cache used for RPC calls is not enabled; fall back to using the // the cache used for RPC calls is not enabled; fall back to using the
// streaming mechanism to serve such requests // streaming mechanism to serve such requests
if (inProgressOk && inProgressTailingEnabled) { if (inProgressOk && inProgressTailingEnabled) {
LOG.info("Tailing edits starting from txn ID " + fromTxnId + if (LOG.isDebugEnabled()) {
" via RPC mechanism"); LOG.debug("Tailing edits starting from txn ID " + fromTxnId +
" via RPC mechanism");
}
try { try {
Collection<EditLogInputStream> rpcStreams = new ArrayList<>(); Collection<EditLogInputStream> rpcStreams = new ArrayList<>();
selectRpcInputStreams(rpcStreams, fromTxnId, onlyDurableTxns); selectRpcInputStreams(rpcStreams, fromTxnId, onlyDurableTxns);