HDFS-7939. Two fsimage_rollback_* files are created which are not deleted after rollback. (Contributed by J.Andreina)
(cherry picked from commit 987c9e12e1
)
Conflicts:
hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt
This commit is contained in:
parent
0e99da620d
commit
4aba069b37
|
@ -148,6 +148,9 @@ Release 2.8.0 - UNRELEASED
|
||||||
HDFS-8096. DatanodeMetrics#blocksReplicated will get incremented early and
|
HDFS-8096. DatanodeMetrics#blocksReplicated will get incremented early and
|
||||||
even for failed transfers (vinayakumarb)
|
even for failed transfers (vinayakumarb)
|
||||||
|
|
||||||
|
HDFS-7939. Two fsimage_rollback_* files are created which are not deleted
|
||||||
|
after rollback. (J.Andreina via vinayakumarb)
|
||||||
|
|
||||||
Release 2.7.1 - UNRELEASED
|
Release 2.7.1 - UNRELEASED
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -711,6 +711,8 @@ public class FSImage implements Closeable {
|
||||||
true);
|
true);
|
||||||
// purge all the checkpoints after the marker
|
// purge all the checkpoints after the marker
|
||||||
archivalManager.purgeCheckpoinsAfter(NameNodeFile.IMAGE, ckptId);
|
archivalManager.purgeCheckpoinsAfter(NameNodeFile.IMAGE, ckptId);
|
||||||
|
// HDFS-7939: purge all old fsimage_rollback_*
|
||||||
|
archivalManager.purgeCheckpoints(NameNodeFile.IMAGE_ROLLBACK);
|
||||||
String nameserviceId = DFSUtil.getNamenodeNameServiceId(conf);
|
String nameserviceId = DFSUtil.getNamenodeNameServiceId(conf);
|
||||||
if (HAUtil.isHAEnabled(conf, nameserviceId)) {
|
if (HAUtil.isHAEnabled(conf, nameserviceId)) {
|
||||||
// close the editlog since it is currently open for write
|
// close the editlog since it is currently open for write
|
||||||
|
|
Loading…
Reference in New Issue