Repository: tez Updated Branches: refs/heads/branch-0.7 73a677a12 -> e0bd87f9b
TEZ-3046. Compilation issue in tez-runtime-internals of branch-0.7 Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/e0bd87f9 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/e0bd87f9 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/e0bd87f9 Branch: refs/heads/branch-0.7 Commit: e0bd87f9be006988a19e8dbfac0735cdfbf8c7ed Parents: 73a677a Author: Jonathan Eagles <[email protected]> Authored: Tue Jan 19 14:08:50 2016 -0600 Committer: Jonathan Eagles <[email protected]> Committed: Tue Jan 19 14:08:50 2016 -0600 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../apache/tez/runtime/LogicalIOProcessorRuntimeTask.java | 10 ++-------- 2 files changed, 3 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/e0bd87f9/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 09b29cc..4457dc4 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -7,6 +7,7 @@ INCOMPATIBLE CHANGES TEZ-2972. Avoid task rescheduling when a node turns unhealthy ALL CHANGES + TEZ-3046. Compilation issue in tez-runtime-internals of branch-0.7 TEZ-2937. Can Processor.close() be called after closing inputs and outputs? TEZ-3037. History URL should be set regardless of which history logging service is enabled. TEZ-2129. Task and Attempt views should contain links to the logs http://git-wip-us.apache.org/repos/asf/tez/blob/e0bd87f9/tez-runtime-internals/src/main/java/org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java ---------------------------------------------------------------------- diff --git a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java index e85eaeb..99e9cb7 100644 --- a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java +++ b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java @@ -849,16 +849,10 @@ public class LogicalIOProcessorRuntimeTask extends RuntimeTask { try { processorClosed = true; processor.close(); - LOG.info("Closed processor for vertex={}, index={}, interruptedStatus={}", + LOG.info("Closed processor for vertex={}, index={}", processor .getContext().getTaskVertexName(), - processor.getContext().getTaskVertexIndex(), - Thread.currentThread().isInterrupted()); - maybeResetInterruptStatus(); - } catch (InterruptedException ie) { - //reset the status - LOG.info("Resetting interrupt for processor"); - Thread.currentThread().interrupt(); + processor.getContext().getTaskVertexIndex()); } catch (Throwable e) { LOG.warn( "Ignoring Exception when closing processor(cleanup). Exception class={}, message={}" +
