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 2014/03/20 00:52:56 UTC
git commit: TEZ-955. Tez should close inputs after calling
processor's close. (hitesh)
Repository: incubator-tez
Updated Branches:
refs/heads/master 4669d71cf -> 2775c8ad0
TEZ-955. Tez should close inputs after calling processor's close. (hitesh)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/2775c8ad
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/2775c8ad
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/2775c8ad
Branch: refs/heads/master
Commit: 2775c8ad0ad4f1a4cfe1935b3233aa4007e06224
Parents: 4669d71
Author: Hitesh Shah <hi...@apache.org>
Authored: Wed Mar 19 16:51:23 2014 -0700
Committer: Hitesh Shah <hi...@apache.org>
Committed: Wed Mar 19 16:51:51 2014 -0700
----------------------------------------------------------------------
.../org/apache/tez/runtime/LogicalIOProcessorRuntimeTask.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/2775c8ad/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 41326b9..92d6b07 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
@@ -312,6 +312,9 @@ public class LogicalIOProcessorRuntimeTask extends RuntimeTask {
"Can only run while in RUNNING state. Current: " + this.state);
this.state = State.CLOSED;
+ // Close the Processor.
+ processor.close();
+
// Close the Inputs.
for (InputSpec inputSpec : inputSpecs) {
String srcVertexName = inputSpec.getSourceVertexName();
@@ -321,9 +324,6 @@ public class LogicalIOProcessorRuntimeTask extends RuntimeTask {
srcVertexName, taskSpec.getTaskAttemptID());
}
- // Close the Processor.
- processor.close();
-
// Close the Outputs.
for (OutputSpec outputSpec : outputSpecs) {
String destVertexName = outputSpec.getDestinationVertexName();