From f11de58f2c6a42da94f3bcacf2e832b552dfe210 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BE=90=E8=89=BA=E4=B8=B9?= <53546877+Craven1701@users.noreply.github.com> Date: Mon, 14 Jul 2025 19:41:38 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=AD=A3=E5=88=99=E5=8C=B9?= =?UTF-8?q?=E9=85=8D=E8=A7=84=E5=88=99=EF=BC=8C=E9=81=BF=E5=85=8D=E5=BD=93?= =?UTF-8?q?logger.thriftserver.level=3DINFO=E7=9A=84=E6=97=B6=E5=80=99?= =?UTF-8?q?=E5=8C=B9=E9=85=8D=E5=88=B0=E6=97=A5=E5=BF=97=E6=96=87=E4=BB=B6?= =?UTF-8?q?=E4=B8=AD=E7=9A=84Time=20taken?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../omniadvisor/service/spark_service/spark_executor.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/omniadvisor/src/omniadvisor/service/spark_service/spark_executor.py b/omniadvisor/src/omniadvisor/service/spark_service/spark_executor.py index af1ee9c2d..e27dcaf3e 100644 --- a/omniadvisor/src/omniadvisor/service/spark_service/spark_executor.py +++ b/omniadvisor/src/omniadvisor/service/spark_service/spark_executor.py @@ -2,6 +2,7 @@ import re from common.constant import OA_CONF from omniadvisor.utils.utils import run_cmd +from omniadvisor.utils.logger import global_logger class SparkExecutor: @@ -39,12 +40,16 @@ class SparkExecutor: pattern = r"Application Id:\s*(.*)" match = re.search(pattern, item) if match: + global_logger.debug("Matched! Pattern: %s, item: %s", pattern, item) application_id = match.group(1).strip() elif "Time taken" in item: - pattern = r"Time taken:\s*(.*)seconds" + pattern = r"^Time taken:\s*(.*)seconds" match = re.search(pattern, item) if match: + global_logger.debug("Matched! Pattern: %s, item: %s", pattern, item) time_taken_list.append(float(match.group(1).strip())) + else: + pass if time_taken_list: total_time_taken = sum(time_taken_list) -- Gitee