TEZ-3046. Compilation issue in tez-runtime-internals of branch-0.7
diff --git a/CHANGES.txt b/CHANGES.txt
index 09b29cc..4457dc4 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -7,6 +7,7 @@
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
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 @@
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={}" +
