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 ra...@apache.org on 2008/03/04 02:04:21 UTC
svn commit: r633341 - in /hadoop/core/trunk: CHANGES.txt
src/java/org/apache/hadoop/dfs/DFSClient.java
Author: rangadi
Date: Mon Mar 3 17:04:18 2008
New Revision: 633341
URL: http://svn.apache.org/viewvc?rev=633341&view=rev
Log:
HADOOP-2931. IOException thrown by DFSOutputStream had wrong stack
trace in some cases. (Michael Bieniosek via rangadi)
Modified:
hadoop/core/trunk/CHANGES.txt
hadoop/core/trunk/src/java/org/apache/hadoop/dfs/DFSClient.java
Modified: hadoop/core/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=633341&r1=633340&r2=633341&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Mon Mar 3 17:04:18 2008
@@ -228,6 +228,9 @@
HADOOP-2809. Fix HOD syslog config syslog-address so that it works.
(Hemanth Yamijala via nigel)
+ HADOOP-2931. IOException thrown by DFSOutputStream had wrong stack
+ trace in some cases. (Michael Bieniosek via rangadi)
+
Release 0.16.0 - 2008-02-07
INCOMPATIBLE CHANGES
Modified: hadoop/core/trunk/src/java/org/apache/hadoop/dfs/DFSClient.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/java/org/apache/hadoop/dfs/DFSClient.java?rev=633341&r1=633340&r2=633341&view=diff
==============================================================================
--- hadoop/core/trunk/src/java/org/apache/hadoop/dfs/DFSClient.java (original)
+++ hadoop/core/trunk/src/java/org/apache/hadoop/dfs/DFSClient.java Mon Mar 3 17:04:18 2008
@@ -1563,7 +1563,7 @@
private DatanodeInfo[] nodes = null; // list of targets for current block
private volatile boolean hasError = false;
private volatile int errorIndex = 0;
- private IOException lastException = new IOException("Stream closed.");
+ private IOException lastException = null;
private long artificialSlowdown = 0;
private class Packet {
@@ -1928,7 +1928,11 @@
private void isClosed() throws IOException {
if (closed) {
- throw lastException;
+ if (lastException != null) {
+ throw lastException;
+ } else {
+ throw new IOException("Stream closed.");
+ }
}
}