public class TezJobMonitor extends Object
Constructor and Description |
---|
TezJobMonitor(Map<String,BaseWork> workMap,
org.apache.tez.dag.api.client.DAGClient dagClient,
HiveConf conf,
org.apache.tez.dag.api.DAG dag,
Context ctx) |
Modifier and Type | Method and Description |
---|---|
String |
getDiagnostics() |
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 String getDiagnostics()
Copyright © 2021 The Apache Software Foundation. All rights reserved.