|
@@ -904,7 +904,7 @@ class FsDatasetImpl implements FsDatasetSpi<FsVolumeImpl> {
|
|
}
|
|
}
|
|
|
|
|
|
@Override // FsDatasetSpi
|
|
@Override // FsDatasetSpi
|
|
- public String recoverClose(ExtendedBlock b, long newGS,
|
|
|
|
|
|
+ public synchronized String recoverClose(ExtendedBlock b, long newGS,
|
|
long expectedBlockLen) throws IOException {
|
|
long expectedBlockLen) throws IOException {
|
|
LOG.info("Recover failed close " + b);
|
|
LOG.info("Recover failed close " + b);
|
|
// check replica's state
|
|
// check replica's state
|