You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by gu...@apache.org on 2013/11/07 01:00:07 UTC
svn commit: r1539502 -
/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java
Author: gunther
Date: Thu Nov 7 00:00:06 2013
New Revision: 1539502
URL: http://svn.apache.org/r1539502
Log:
HIVE-5766: Update call to Tez DAG status to reflect updated API (Gunther Hagleitner)
Modified:
hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java
Modified: hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java
URL: http://svn.apache.org/viewvc/hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java?rev=1539502&r1=1539501&r2=1539502&view=diff
==============================================================================
--- hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java (original)
+++ hive/branches/tez/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobMonitor.java Thu Nov 7 00:00:06 2013
@@ -35,6 +35,7 @@ import org.apache.tez.dag.api.TezExcepti
import org.apache.tez.dag.api.client.DAGClient;
import org.apache.tez.dag.api.client.DAGStatus;
import org.apache.tez.dag.api.client.Progress;
+import org.apache.tez.dag.api.client.StatusGetOpts;
/**
* TezJobMonitor keeps track of a tez job while it's being executed. It will
@@ -76,6 +77,7 @@ public class TezJobMonitor {
int rc = 0;
DAGStatus.State lastState = null;
String lastReport = null;
+ Set<StatusGetOpts> opts = new HashSet<StatusGetOpts>();
console.printInfo("\n");
perfLogger.PerfLogBegin(CLASS_NAME, PerfLogger.TEZ_RUN_DAG);
@@ -84,7 +86,7 @@ public class TezJobMonitor {
while(true) {
try {
- status = dagClient.getDAGStatus();
+ status = dagClient.getDAGStatus(opts);
Map<String, Progress> progressMap = status.getVertexProgress();
DAGStatus.State state = status.getState();