From 41193181d6b75eeecae2729bf98007d9318e351a Mon Sep 17 00:00:00 2001 From: Armand Grillet Date: Wed, 18 Oct 2017 10:38:42 -0700 Subject: [PATCH] Increased level of some verbose logs from master and agent. Increases vlog level of some recurring events to improve readability. Specifically, we now log the following events on vlog level two instead of level one: "Sending heartbeat", "Received ping from ", "Querying resource estimator for oversubscribable resources", "Received oversubscribable resources". Review: https://reviews.apache.org/r/62887/ --- src/master/master.hpp | 2 +- src/slave/slave.cpp | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/master/master.hpp b/src/master/master.hpp index 0ddc98259f6..a3c9530e340 100644 --- a/src/master/master.hpp +++ b/src/master/master.hpp @@ -346,7 +346,7 @@ class Heartbeater : public process::Process> { // Only send a heartbeat if the connection is not closed. if (http.closed().isPending()) { - VLOG(1) << "Sending heartbeat to " << logMessage; + VLOG(2) << "Sending heartbeat to " << logMessage; Message message(heartbeatMessage); http.send(message); diff --git a/src/slave/slave.cpp b/src/slave/slave.cpp index 4d7dc8e9a39..d8477b4e364 100644 --- a/src/slave/slave.cpp +++ b/src/slave/slave.cpp @@ -4963,7 +4963,7 @@ void Slave::executorMessage( // within that (more generous) timeout. void Slave::ping(const UPID& from, bool connected) { - VLOG(1) << "Received ping from " << from; + VLOG(2) << "Received ping from " << from; if (!connected && state == RUNNING) { // This could happen if there is a one-way partition between @@ -6489,7 +6489,7 @@ Future Slave::garbageCollect(const string& path) void Slave::forwardOversubscribed() { - VLOG(1) << "Querying resource estimator for oversubscribable resources"; + VLOG(2) << "Querying resource estimator for oversubscribable resources"; resourceEstimator->oversubscribable() .onAny(defer(self(), &Self::_forwardOversubscribed, lambda::_1)); @@ -6503,7 +6503,7 @@ void Slave::_forwardOversubscribed(const Future& oversubscribable) << (oversubscribable.isFailed() ? oversubscribable.failure() : "future discarded"); } else { - VLOG(1) << "Received oversubscribable resources " + VLOG(2) << "Received oversubscribable resources " << oversubscribable.get() << " from the resource estimator"; // Oversubscribable resources must be tagged as revocable.