HDFS-7199. DFSOutputStream should not silently drop data if DataStreamer crashes with an unchecked exception (rushabhs via cmccabe)
(cherry picked from commit 56257fab1d
)
This commit is contained in:
parent
1ef616ceb7
commit
6f7ce842c0
|
@ -145,6 +145,9 @@ Release 2.7.0 - UNRELEASED
|
||||||
HDFS-7324. haadmin command usage prints incorrect command name.
|
HDFS-7324. haadmin command usage prints incorrect command name.
|
||||||
(Brahma Reddy Battula via suresh)
|
(Brahma Reddy Battula via suresh)
|
||||||
|
|
||||||
|
HDFS-7199. DFSOutputStream should not silently drop data if DataStreamer
|
||||||
|
crashes with an unchecked exception (rushabhs via cmccabe)
|
||||||
|
|
||||||
Release 2.6.0 - UNRELEASED
|
Release 2.6.0 - UNRELEASED
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -692,6 +692,8 @@ public class DFSOutputStream extends FSOutputSummer
|
||||||
}
|
}
|
||||||
if (e instanceof IOException) {
|
if (e instanceof IOException) {
|
||||||
setLastException((IOException)e);
|
setLastException((IOException)e);
|
||||||
|
} else {
|
||||||
|
setLastException(new IOException("DataStreamer Exception: ",e));
|
||||||
}
|
}
|
||||||
hasError = true;
|
hasError = true;
|
||||||
if (errorIndex == -1 && restartingNodeIndex == -1) {
|
if (errorIndex == -1 && restartingNodeIndex == -1) {
|
||||||
|
|
Loading…
Reference in New Issue