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