|
@@ -1117,8 +1117,9 @@ public class TestDirectoryScanner {
|
|
|
|
|
|
@Test
|
|
|
public void testDirectoryScannerInFederatedCluster() throws Exception {
|
|
|
+ HdfsConfiguration conf = new HdfsConfiguration(CONF);
|
|
|
// Create Federated cluster with two nameservices and one DN
|
|
|
- try (MiniDFSCluster cluster = new MiniDFSCluster.Builder(CONF)
|
|
|
+ try (MiniDFSCluster cluster = new MiniDFSCluster.Builder(conf)
|
|
|
.nnTopology(MiniDFSNNTopology.simpleHAFederatedTopology(2))
|
|
|
.numDataNodes(1).build()) {
|
|
|
cluster.waitActive();
|
|
@@ -1134,7 +1135,7 @@ public class TestDirectoryScanner {
|
|
|
int bp2Files = 2;
|
|
|
writeFile(fs2, bp2Files);
|
|
|
// Call the Directory scanner
|
|
|
- scanner = new DirectoryScanner(fds, CONF);
|
|
|
+ scanner = new DirectoryScanner(fds, conf);
|
|
|
scanner.setRetainDiffs(true);
|
|
|
scanner.reconcile();
|
|
|
// Check blocks in corresponding BP
|