This is an automated email from the ASF dual-hosted git repository.
abstractdog 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 914d7550c3e HIVE-28868: Print AM hostname on console (#5739) (Laszlo
Bodor reviewed by Denys Kuzmenko, Kokila N)
914d7550c3e is described below
commit 914d7550c3e296e737dc3c8042c37fd00ff002ef
Author: Bodor Laszlo <[email protected]>
AuthorDate: Thu Apr 3 13:01:38 2025 +0200
HIVE-28868: Print AM hostname on console (#5739) (Laszlo Bodor reviewed by
Denys Kuzmenko, Kokila N)
---
ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezRuntimeContext.java | 1 -
ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java | 4 ++--
2 files changed, 2 insertions(+), 3 deletions(-)
diff --git
a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezRuntimeContext.java
b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezRuntimeContext.java
index 81237d99125..fe5c88a0a9a 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezRuntimeContext.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezRuntimeContext.java
@@ -19,7 +19,6 @@
package org.apache.hadoop.hive.ql.exec.tez;
import org.apache.hadoop.hive.ql.exec.tez.monitoring.TezJobMonitor;
-import org.apache.tez.client.TezClient;
import org.apache.tez.common.counters.CounterGroup;
import org.apache.tez.common.counters.TezCounters;
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java
b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java
index c5c02a242b2..83bd35fbb40 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java
@@ -268,8 +268,8 @@ public int execute() {
// Log all the info required to find the various logs for this query
String dagId = this.dagClient.getDagIdentifierString();
String appId = this.dagClient.getSessionIdentifierString();
- LOG.info("HS2 Host: [{}], Query ID: [{}], Dag ID: [{}], DAG App ID:
[{}]", ServerUtils.hostname(), queryId,
- dagId, appId);
+ LOG.info("HS2 Host: [{}], Query ID: [{}], Dag ID: [{}], DAG App ID:
[{}], DAG App address: [{}]",
+ ServerUtils.hostname(), queryId, dagId, appId,
session.getSession().getAmHost());
LogUtils.putToMDC(LogUtils.DAGID_KEY, dagId);
this.jobID = dagId;
runtimeContext.setDagId(dagId);