Blob Blame History Raw
From b41f86b31b29cd9e47e7cccbdeb8c95d3f513da9 Mon Sep 17 00:00:00 2001
From: Marek Goldmann <marek.goldmann@gmail.com>
Date: Thu, 28 Nov 2013 12:07:09 +0100
Subject: [PATCH] Support for hadoop 2.2.0

---
 .../src/main/java/org/apache/avro/mapred/tether/TetheredProcess.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lang/java/mapred/src/main/java/org/apache/avro/mapred/tether/TetheredProcess.java b/lang/java/mapred/src/main/java/org/apache/avro/mapred/tether/TetheredProcess.java
index 40a1056..fac7589 100644
--- a/lang/java/mapred/src/main/java/org/apache/avro/mapred/tether/TetheredProcess.java
+++ b/lang/java/mapred/src/main/java/org/apache/avro/mapred/tether/TetheredProcess.java
@@ -154,7 +154,7 @@ class TetheredProcess  {
     File stdout = TaskLog.getTaskLogFile(taskid, false, TaskLog.LogName.STDOUT);
     File stderr = TaskLog.getTaskLogFile(taskid, false, TaskLog.LogName.STDERR);
     long logLength = TaskLog.getTaskLogLength(job);
-    command = TaskLog.captureOutAndError(command, stdout, stderr, logLength);
+    command = TaskLog.captureOutAndError(null, command, stdout, stderr, logLength, false);
     stdout.getParentFile().mkdirs();
     stderr.getParentFile().mkdirs();
 
-- 
1.8.4.2