You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by to...@apache.org on 2007/04/24 14:03:20 UTC
svn commit: r531891 - in /lucene/hadoop/trunk: CHANGES.txt
src/java/org/apache/hadoop/mapred/TaskLogAppender.java
Author: tomwhite
Date: Tue Apr 24 05:03:19 2007
New Revision: 531891
URL: http://svn.apache.org/viewvc?view=rev&rev=531891
Log:
HADOOP-1271. Fix StreamBaseRecordReader to be able to log record data that's not UTF-8. Contributed by Arun C Murthy.
Modified:
lucene/hadoop/trunk/CHANGES.txt
lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskLogAppender.java
Modified: lucene/hadoop/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?view=diff&rev=531891&r1=531890&r2=531891
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Tue Apr 24 05:03:19 2007
@@ -242,6 +242,9 @@
not count a lost tasktracker against the job.
(Arun C Murthy via tomwhite)
+73. HADOOP-1271. Fix StreamBaseRecordReader to be able to log record
+ data that's not UTF-8. (Arun C Murthy via tomwhite)
+
Release 0.12.3 - 2007-04-06
Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskLogAppender.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskLogAppender.java?view=diff&rev=531891&r1=531890&r2=531891
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskLogAppender.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/mapred/TaskLogAppender.java Tue Apr 24 05:03:19 2007
@@ -48,7 +48,8 @@
// Log the message to the task's log
String logMessage = this.layout.format(event);
try {
- taskLogWriter.write(logMessage.getBytes(), 0, logMessage.length());
+ byte[] logMessageData = logMessage.getBytes();
+ taskLogWriter.write(logMessageData, 0, logMessageData.length);
} catch (IOException ioe) {
errorHandler.error("Failed to log: '" + logMessage +
"' to the task's logging infrastructure with the exception: " +