public class TezJobMonitor extends Object
Constructor and Description |
---|
TezJobMonitor(List<BaseWork> topSortedWorks,
org.apache.tez.dag.api.client.DAGClient dagClient,
HiveConf conf,
org.apache.tez.dag.api.DAG dag,
Context ctx,
org.apache.tez.common.counters.TezCounters counters) |
Modifier and Type | Method and Description |
---|---|
String |
getDiagnostics() |
HiveConf |
getHiveConf() |
static void |
initShutdownHook() |
static void |
killRunningJobs()
killRunningJobs tries to terminate execution of all
currently running tez queries.
|
int |
monitorExecution() |
public static void initShutdownHook()
public int monitorExecution()
public static void killRunningJobs()
TezJobExecHelper.killRunningJobs()
makes use of
this method via reflection.public HiveConf getHiveConf()
public String getDiagnostics()
Copyright © 2022 The Apache Software Foundation. All rights reserved.