You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by hi...@apache.org on 2015/11/19 00:01:39 UTC
tez git commit: TEZ-2480. Exception when closing output is ignored.
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 <hi...@apache.org>
Authored: Wed Nov 18 15:01:28 2015 -0800
Committer: Hitesh Shah <hi...@apache.org>
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());