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 cu...@apache.org on 2007/07/19 23:46:54 UTC
svn commit: r557786 - in /lucene/hadoop/trunk: CHANGES.txt
src/java/org/apache/hadoop/dfs/DataNode.java
Author: cutting
Date: Thu Jul 19 14:46:53 2007
New Revision: 557786
URL: http://svn.apache.org/viewvc?view=rev&rev=557786
Log:
HADOOP-1624. Fix an infinite loop in datanode. Contributed by Raghu.
Modified:
lucene/hadoop/trunk/CHANGES.txt
lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/DataNode.java
Modified: lucene/hadoop/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?view=diff&rev=557786&r1=557785&r2=557786
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Thu Jul 19 14:46:53 2007
@@ -382,6 +382,8 @@
118. HADOOP-1625. Fix a "could not move files" exception in datanode.
(Raghu Angadi via cutting)
+119. HADOOP-1624. Fix an infinite loop in datanode. (Raghu Angadi via cutting)
+
Release 0.13.0 - 2007-06-08
Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/DataNode.java
URL: http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/DataNode.java?view=diff&rev=557786&r1=557785&r2=557786
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/DataNode.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/dfs/DataNode.java Thu Jul 19 14:46:53 2007
@@ -37,7 +37,6 @@
import java.io.*;
import java.net.*;
import java.util.*;
-import org.apache.hadoop.dfs.FSConstants.StartupOption;
import org.apache.hadoop.metrics.MetricsContext;
import org.apache.hadoop.metrics.MetricsRecord;
import org.apache.hadoop.metrics.Updater;
@@ -736,13 +735,12 @@
break;
case OP_READ_METADATA:
readMetadata( in );
-
+ break;
default:
- System.out.println("Faulty op: " + op);
throw new IOException("Unknown opcode " + op + "in data stream");
}
} catch (Throwable t) {
- LOG.error("DataXCeiver", t);
+ LOG.error("DataXceiver: " + StringUtils.stringifyException(t));
} finally {
try {
xceiverCount.decr();