diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java index f2ed07add5..6a2b334425 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java @@ -233,7 +233,8 @@ public int execute(DriverContext driverContext) { } // finally monitor will print progress until the job is done - TezJobMonitor monitor = new TezJobMonitor(work.getAllWork(), dagClient, conf, dag, ctx); + TezJobMonitor monitor = new TezJobMonitor(work.getAllWork(), + dagClient, conf, dag, ctx, perfLogger); rc = monitor.monitorExecution(); if (rc != 0) { diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java index d3fe190e4e..ad5f0c9b59 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java @@ -76,7 +76,7 @@ Licensed to the Apache Software Foundation (ASF) under one private static final int MAX_RETRY_INTERVAL = 2500; private static final int MAX_RETRY_FAILURES = (MAX_RETRY_INTERVAL / MAX_CHECK_INTERVAL) + 1; - private final PerfLogger perfLogger = SessionState.getPerfLogger(); + private final PerfLogger perfLogger; private static final List shutdownList; private final List topSortedWorks; @@ -114,7 +114,7 @@ public static void initShutdownHook() { private final RenderStrategy.UpdateFunction updateFunction; public TezJobMonitor(List topSortedWorks, final DAGClient dagClient, HiveConf conf, DAG dag, - Context ctx) { + Context ctx, PerfLogger perfLogger) { this.topSortedWorks = topSortedWorks; this.dagClient = dagClient; this.hiveConf = conf; @@ -122,6 +122,7 @@ public TezJobMonitor(List topSortedWorks, final DAGClient dagClient, H this.context = ctx; console = SessionState.getConsole(); updateFunction = updateFunction(); + this.perfLogger = perfLogger; } private RenderStrategy.UpdateFunction updateFunction() {