From 581dfa41c044f905f1260a84bee0977738f36be1 Mon Sep 17 00:00:00 2001 From: Akash Verma <138790903+akashverma0786@users.noreply.github.com> Date: Fri, 24 Jan 2025 13:44:55 +0530 Subject: [PATCH] Fix: Updated queries causing arithmetic overflow error (#19505) Co-authored-by: Akash Verma (cherry picked from commit 68a0e6af58e2f2c2497ed4149bf8e41ba2b309b1) --- .../ingestion/source/database/mssql/queries.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/ingestion/src/metadata/ingestion/source/database/mssql/queries.py b/ingestion/src/metadata/ingestion/source/database/mssql/queries.py index d9bab948e08..0ed3f06da06 100644 --- a/ingestion/src/metadata/ingestion/source/database/mssql/queries.py +++ b/ingestion/src/metadata/ingestion/source/database/mssql/queries.py @@ -20,8 +20,8 @@ MSSQL_SQL_STATEMENT = textwrap.dedent( db.NAME database_name, t.text query_text, s.last_execution_time start_time, - DATEADD(s, s.total_elapsed_time/1000, s.last_execution_time) end_time, - s.total_elapsed_time/1000 duration, + DATEADD(s, s.last_elapsed_time/1000000, s.last_execution_time) end_time, + s.last_elapsed_time/1000000 duration, NULL schema_name, NULL query_type, NULL user_name, @@ -209,7 +209,7 @@ MSSQL_GET_STORED_PROCEDURE_QUERIES = textwrap.dedent( WITH SP_HISTORY (start_time, end_time, procedure_name, query_text) AS ( select s.last_execution_time start_time, - DATEADD(s, s.total_elapsed_time/1000, s.last_execution_time) end_time, + DATEADD(s, s.last_elapsed_time/1000000, s.last_execution_time) end_time, OBJECT_NAME(object_id, database_id) as procedure_name, text as query_text from sys.dm_exec_procedure_stats s @@ -222,8 +222,8 @@ Q_HISTORY (database_name, query_text, start_time, end_time, duration,query_type, db.NAME database_name, t.text query_text, s.last_execution_time start_time, - DATEADD(s, s.total_elapsed_time/1000, s.last_execution_time) end_time, - s.total_elapsed_time/1000 duration, + DATEADD(s, s.last_elapsed_time/1000000, s.last_execution_time) end_time, + s.last_elapsed_time/1000000 duration, case when t.text LIKE '%%MERGE%%' then 'MERGE' when t.text LIKE '%%UPDATE%%' then 'UPDATE'