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 69cbe0b..58f0b33 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 @@ -627,6 +627,17 @@ public void close() throws IOException { dagClient.close(); // Don't sync. } + public String getDagIdentifierString() { + // TODO: Implement this when tez is upgraded. TEZ-3550 + return null; + } + + public String getSessionIdentifierString() { + // TODO: Implement this when tez is upgraded. TEZ-3550 + return null; + } + + @Override public String getExecutionContext() { return dagClient.getExecutionContext(); // Don't sync.