HDFS-7199. DFSOutputStream should not silently drop data if DataStreamer crashes with an unchecked exception (rushabhs via cmccabe)
(cherry picked from commit56257fab1d
) (cherry picked from commit6f7ce842c0
)
This commit is contained in:
parent
0d573cc4c0
commit
8702cc2360
|
@ -890,6 +890,9 @@ Release 2.6.0 - UNRELEASED
|
||||||
|
|
||||||
HDFS-7305. NPE seen in wbhdfs FS while running SLive. (jing9)
|
HDFS-7305. NPE seen in wbhdfs FS while running SLive. (jing9)
|
||||||
|
|
||||||
|
HDFS-7199. DFSOutputStream should not silently drop data if DataStreamer
|
||||||
|
crashes with an unchecked exception (rushabhs via cmccabe)
|
||||||
|
|
||||||
BREAKDOWN OF HDFS-6584 ARCHIVAL STORAGE
|
BREAKDOWN OF HDFS-6584 ARCHIVAL STORAGE
|
||||||
|
|
||||||
HDFS-6677. Change INodeFile and FSImage to support storage policy ID.
|
HDFS-6677. Change INodeFile and FSImage to support storage policy ID.
|
||||||
|
|
|
@ -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