You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@heron.apache.org by ni...@apache.org on 2022/05/30 02:11:44 UTC
[incubator-heron] branch master updated: Reduce the DEBUG logging in Tracker timeline API calls (#3836)
This is an automated email from the ASF dual-hosted git repository.
nicknezis pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
The following commit(s) were added to refs/heads/master by this push:
new 439896f2659 Reduce the DEBUG logging in Tracker timeline API calls (#3836)
439896f2659 is described below
commit 439896f2659fa794575a4baaff54284d95295efb
Author: choi se <th...@gmail.com>
AuthorDate: Mon May 30 11:11:39 2022 +0900
Reduce the DEBUG logging in Tracker timeline API calls (#3836)
---
heron/common/src/python/utils/log.py | 3 +++
heron/tools/tracker/src/python/metricstimeline.py | 1 -
2 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/heron/common/src/python/utils/log.py b/heron/common/src/python/utils/log.py
index b7fb209f3db..f83df600275 100644
--- a/heron/common/src/python/utils/log.py
+++ b/heron/common/src/python/utils/log.py
@@ -27,6 +27,9 @@ import colorlog
# pylint: disable=invalid-name
logging.basicConfig()
Log = logging.getLogger()
+logging.getLogger('javaobj').setLevel(logging.INFO)
+logging.getLogger('httpx').setLevel(logging.INFO)
+logging.getLogger('kazoo').setLevel(logging.INFO)
# time formatter - date - time - UTC offset
# e.g. "08/16/1988 21:30:00 +1030"
diff --git a/heron/tools/tracker/src/python/metricstimeline.py b/heron/tools/tracker/src/python/metricstimeline.py
index 5e55cd4abcf..1f18003ba35 100644
--- a/heron/tools/tracker/src/python/metricstimeline.py
+++ b/heron/tools/tracker/src/python/metricstimeline.py
@@ -84,7 +84,6 @@ async def get_metrics_timeline(
# Form and send the http request.
url = f"http://{tmanager.host}:{tmanager.stats_port}/stats"
- Log.debug(f"Making HTTP call to fetch metrics: {url}")
async with httpx.AsyncClient() as client:
result = await client.post(url, data=request_parameters.SerializeToString())