tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jeag...@apache.org
Subject tez git commit: TEZ-3046. Compilation issue in tez-runtime-internals of branch-0.7
Date Tue, 19 Jan 2016 20:09:02 GMT
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 <jeagles@yahoo-inc.com>
Authored: Tue Jan 19 14:08:50 2016 -0600
Committer: Jonathan Eagles <jeagles@yahoo-inc.com>
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={}"
+


Mime
View raw message