|
36 | 36 | import java.util.function.Supplier; |
37 | 37 | import org.apache.hadoop.hdfs.DistributedFileSystem; |
38 | 38 | import org.apache.hadoop.hdfs.protocol.HdfsConstants.RollingUpgradeAction; |
39 | | -import org.apache.hadoop.hdfs.protocol.RollingUpgradeInfo; |
40 | 39 | import org.apache.hadoop.hdfs.server.common.HttpGetFailedException; |
41 | 40 | import org.apache.hadoop.hdfs.server.namenode.FSImage; |
42 | 41 | import org.apache.hadoop.hdfs.server.namenode.NameNodeLayoutVersion; |
@@ -218,7 +217,7 @@ public void testRollingUpgradeBootstrapStandby() throws Exception { |
218 | 217 | // Start rolling upgrade |
219 | 218 | fs.rollingUpgrade(RollingUpgradeAction.PREPARE); |
220 | 219 | LambdaTestUtils.await(60000, 1000, () -> |
221 | | - fs.rollingUpgrade(RollingUpgradeAction.QUERY).createdRollbackImages()); |
| 220 | + fs.rollingUpgrade(RollingUpgradeAction.QUERY).createdRollbackImages()); |
222 | 221 | // After the rollback image is created the standby is not needed |
223 | 222 | cluster.shutdownNameNode(1); |
224 | 223 | removeStandbyNameDirs(); |
@@ -247,8 +246,8 @@ public void testRollingUpgradeBootstrapStandby() throws Exception { |
247 | 246 | long expectedCheckpointTxId = NameNodeAdapter.getNamesystem(nn0) |
248 | 247 | .getFSImage().getMostRecentCheckpointTxId(); |
249 | 248 | long expectedRollbackTxId = NameNodeAdapter.getNamesystem(nn0) |
250 | | - .getFSImage().getMostRecentNameNodeFileTxId( |
251 | | - NNStorage.NameNodeFile.IMAGE_ROLLBACK); |
| 249 | + .getFSImage().getMostRecentNameNodeFileTxId( |
| 250 | + NNStorage.NameNodeFile.IMAGE_ROLLBACK); |
252 | 251 | assertEquals(11, expectedCheckpointTxId); |
253 | 252 |
|
254 | 253 | for (int i = 1; i < maxNNCount; i++) { |
|
0 commit comments