|
@@ -170,6 +170,7 @@ class RedundantEditLogInputStream extends EditLogInputStream {
|
|
}
|
|
}
|
|
return nextOp();
|
|
return nextOp();
|
|
} catch (IOException e) {
|
|
} catch (IOException e) {
|
|
|
|
+ LOG.warn("encountered an exception", e);
|
|
return null;
|
|
return null;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -228,7 +229,8 @@ class RedundantEditLogInputStream extends EditLogInputStream {
|
|
"streams are shorter than the current one! The best " +
|
|
"streams are shorter than the current one! The best " +
|
|
"remaining edit log ends at transaction " +
|
|
"remaining edit log ends at transaction " +
|
|
newLast + ", but we thought we could read up to transaction " +
|
|
newLast + ", but we thought we could read up to transaction " +
|
|
- oldLast + ". If you continue, metadata will be lost forever!");
|
|
|
|
|
|
+ oldLast + ". If you continue, metadata will be lost forever!",
|
|
|
|
+ prevException);
|
|
}
|
|
}
|
|
LOG.error("Got error reading edit log input stream " +
|
|
LOG.error("Got error reading edit log input stream " +
|
|
streams[curIdx].getName() + "; failing over to edit log " +
|
|
streams[curIdx].getName() + "; failing over to edit log " +
|