Repository: tez Updated Branches: refs/heads/master 28fb6522f -> c07f284ac
TEZ-2480. Exception when closing output is ignored. Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/c07f284a Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/c07f284a Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/c07f284a Branch: refs/heads/master Commit: c07f284ac1c764b32841a872dca1addaf46906a2 Parents: 28fb652 Author: Hitesh Shah <[email protected]> Authored: Wed Nov 18 15:01:28 2015 -0800 Committer: Hitesh Shah <[email protected]> Committed: Wed Nov 18 15:01:28 2015 -0800 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java | 6 +++--- 2 files changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/c07f284a/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index a6c4a63..ea88aff 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -8,6 +8,7 @@ INCOMPATIBLE CHANGES TEZ-2948. Stop using dagName in the dagComplete notification to TaskCommunicators. ALL CHANGES: + TEZ-2480. Exception when closing output is ignored. TEZ-2944. NPE in TestProcessorContext. TEZ-2945. TEZ-2740 addendum to update API with currently supported parameters TEZ-2933. Tez UI: Load application details from RM when available http://git-wip-us.apache.org/repos/asf/tez/blob/c07f284a/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 6b9b016..1a59310 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 @@ -858,7 +858,7 @@ public class LogicalIOProcessorRuntimeTask extends RuntimeTask { } catch (Throwable e) { LOG.warn( "Ignoring Exception when closing processor(cleanup). Exception class={}, message={}" + - e.getClass().getName(), e.getMessage(), e); + e.getClass().getName(), e.getMessage()); } } @@ -879,7 +879,7 @@ public class LogicalIOProcessorRuntimeTask extends RuntimeTask { } catch (Throwable e) { LOG.warn( "Ignoring exception when closing input {}(cleanup). Exception class={}, message={}", - srcVertexName, e.getClass().getName(), e.getMessage(), e); + srcVertexName, e.getClass().getName(), e.getMessage()); } finally { LOG.info("Closed input for vertex={}, sourceVertex={}, interruptedStatus={}", processor .getContext().getTaskVertexName(), srcVertexName, Thread.currentThread().isInterrupted()); @@ -903,7 +903,7 @@ public class LogicalIOProcessorRuntimeTask extends RuntimeTask { } catch (Throwable e) { LOG.warn( "Ignoring exception when closing output {}(cleanup). Exception class={}, message={}", - destVertexName, e.getClass().getName(), e.getMessage(), e); + destVertexName, e.getClass().getName(), e.getMessage()); } finally { LOG.info("Closed input for vertex={}, sourceVertex={}, interruptedStatus={}", processor .getContext().getTaskVertexName(), destVertexName, Thread.currentThread().isInterrupted());
