|
@@ -88,7 +88,12 @@ public class EditLogFileOutputStream extends EditLogOutputStream {
|
|
} else {
|
|
} else {
|
|
rp = new RandomAccessFile(name, "rw");
|
|
rp = new RandomAccessFile(name, "rw");
|
|
}
|
|
}
|
|
- fp = new FileOutputStream(rp.getFD()); // open for append
|
|
|
|
|
|
+ try {
|
|
|
|
+ fp = new FileOutputStream(rp.getFD()); // open for append
|
|
|
|
+ } catch (IOException e) {
|
|
|
|
+ IOUtils.closeStream(rp);
|
|
|
|
+ throw e;
|
|
|
|
+ }
|
|
fc = rp.getChannel();
|
|
fc = rp.getChannel();
|
|
fc.position(fc.size());
|
|
fc.position(fc.size());
|
|
}
|
|
}
|