Skip to content

Commit

Permalink
Fix HA tests
Browse files Browse the repository at this point in the history
  • Loading branch information
Kimahriman committed Dec 4, 2023
1 parent 8b5719b commit b915664
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion rust/minidfs/src/main/java/main/Main.java
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ public static void main(String args[]) throws Exception {
hdfsConf.addResource(routerDfs.getRouterClientConf());
hdfsConf.set(FS_DEFAULT_NAME_KEY, "hdfs://fed");
} else {
MiniDFSNNTopology nnTopology = generateTopology(flags, conf);
MiniDFSNNTopology nnTopology = generateTopology(flags, hdfsConf);

int numDataNodes = 1;
if (flags.contains("ec")) {
Expand Down

0 comments on commit b915664

Please sign in to comment.