|
@@ -67,7 +67,6 @@ public class EditLogFileInputStream extends EditLogInputStream {
|
|
|
CLOSED
|
|
|
}
|
|
|
private State state = State.UNINIT;
|
|
|
- private InputStream fStream = null;
|
|
|
private int logVersion = 0;
|
|
|
private FSEditLogOp.Reader reader = null;
|
|
|
private FSEditLogLoader.PositionTrackingInputStream tracker = null;
|
|
@@ -153,6 +152,7 @@ public class EditLogFileInputStream extends EditLogInputStream {
|
|
|
throws LogHeaderCorruptException, IOException {
|
|
|
Preconditions.checkState(state == State.UNINIT);
|
|
|
BufferedInputStream bin = null;
|
|
|
+ InputStream fStream = null;
|
|
|
try {
|
|
|
fStream = log.getInputStream();
|
|
|
bin = new BufferedInputStream(fStream);
|