(hive) branch master updated: HIVE-28648: OTEL: Add Execution Engine as part of the Query Data. (#5565). (Ayush Saxena, reviewed by Simhadri Govindappa, Tanishq Chugh, Attila Turoczy)

[ayushsaxena]

This is an automated email from the ASF dual-hosted git repository.

ayushsaxena pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new 4e832396158 HIVE-28648: OTEL: Add Execution Engine as part of the 
Query Data. (#5565). (Ayush Saxena, reviewed by Simhadri Govindappa, Tanishq 
Chugh, Attila Turoczy)
4e832396158 is described below

commit 4e832396158530da9171c7f912e700411aeeae0f
Author: Ayush Saxena <ayushsax...@apache.org>
AuthorDate: Wed Nov 27 23:23:06 2024 +0530

    HIVE-28648: OTEL: Add Execution Engine as part of the Query Data. (#5565). 
(Ayush Saxena, reviewed by Simhadri Govindappa, Tanishq Chugh, Attila Turoczy)
---
 service/src/java/org/apache/hive/service/servlet/OTELExporter.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/service/src/java/org/apache/hive/service/servlet/OTELExporter.java 
b/service/src/java/org/apache/hive/service/servlet/OTELExporter.java
index ceef60f1c7a..4b179bcd670 100644
--- a/service/src/java/org/apache/hive/service/servlet/OTELExporter.java
+++ b/service/src/java/org/apache/hive/service/servlet/OTELExporter.java
@@ -111,7 +111,8 @@ public class OTELExporter extends Thread {
                 .setStartTimestamp(lQuery.getBeginTime(), 
TimeUnit.MILLISECONDS).startSpan()
                 .setAttribute("QueryId", queryID)
                 .setAttribute("QueryString", 
lQuery.getQueryDisplay().getQueryString())
-                .setAttribute("UserName", lQuery.getUserName());
+                .setAttribute("UserName", lQuery.getUserName())
+                .setAttribute("ExecutionEngine", lQuery.getExecutionEngine());
         if (lQuery.getQueryDisplay().getErrorMessage() != null) {
           initSpan.setAttribute("ErrorMessage", 
lQuery.getQueryDisplay().getErrorMessage());
         }
@@ -168,7 +169,8 @@ public class OTELExporter extends Thread {
                 .setStartTimestamp(hQuery.getBeginTime(), 
TimeUnit.MILLISECONDS).startSpan()
                 .setAttribute("QueryId", hQueryId)
                 .setAttribute("QueryString", 
hQuery.getQueryDisplay().getQueryString())
-                .setAttribute("UserName", hQuery.getUserName());
+                .setAttribute("UserName", hQuery.getUserName())
+                .setAttribute("ExecutionEngine", hQuery.getExecutionEngine());
         if (hQuery.getQueryDisplay().getErrorMessage() != null) {
           initSpan.setAttribute("ErrorMessage", 
hQuery.getQueryDisplay().getErrorMessage());
         }