Skip to content

Commit e4e3c55

Browse files
committed
Whitespace cleanup.
1 parent 1ff6698 commit e4e3c55

File tree

1 file changed

+6
-8
lines changed

1 file changed

+6
-8
lines changed

hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestObserverWithRouter.java

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -984,31 +984,29 @@ public void testRestartingNamenodeWithStateIDContextDisabled(ConfigSetting confi
984984
Path path = new Path("/testFile1");
985985
// Send Create call to active
986986
fileSystem.create(path).close();
987-
987+
988988
// Send read request
989989
fileSystem.open(path).close();
990-
990+
991991
long observerCount1 = routerContext.getRouter().getRpcServer().getRPCMetrics().getObserverProxyOps();
992-
992+
993993
// Restart active namenodes and disable sending state id.
994994
restartActiveWithStateIDContextDisabled();
995-
995+
996996
Configuration conf = getConfToEnableObserverReads(configSetting);
997997
conf.setBoolean("fs.hdfs.impl.disable.cache", true);
998998
FileSystem fileSystem2 = routerContext.getFileSystem(conf);
999999
fileSystem2.msync();
10001000
fileSystem2.open(path).close();
1001-
1001+
10021002
long observerCount2 = routerContext.getRouter().getRpcServer().getRPCMetrics().getObserverProxyOps();
10031003
assertEquals("There should no extra calls to the observer", observerCount1, observerCount2);
10041004

10051005
fileSystem.open(path).close();
10061006
long observerCount3 = routerContext.getRouter().getRpcServer().getRPCMetrics().getObserverProxyOps();
10071007
assertTrue("Old filesystem will send calls to observer", observerCount3 > observerCount2);
1008-
10091008
}
1010-
1011-
1009+
10121010
void restartActiveWithStateIDContextDisabled() throws Exception {
10131011
for (int nnIndex = 0; nnIndex < cluster.getNamenodes().size(); nnIndex++) {
10141012
NameNode nameNode = cluster.getCluster().getNameNode(nnIndex);

0 commit comments

Comments
 (0)