Skip to content

Commit

Permalink
ns
Browse files Browse the repository at this point in the history
  • Loading branch information
belaban committed Oct 3, 2024
1 parent 8856095 commit f3c6a11
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -191,6 +191,7 @@ static void _testConcurrentMergeMultiplePartitions(String cluster_name) throws E
JChannel[] channels=null;
try {
channels=create(true, cluster_name, "A", "B", "C", "D", "E", "F", "G", "H");
Util.waitUntilAllChannelsHaveSameView(5000, 500, channels);
print(channels);
View view=channels[channels.length -1].getView();
assert view.size() == channels.length : "view is " + view;
Expand Down Expand Up @@ -482,7 +483,7 @@ private static JChannel[] create(boolean simple_ids, String cluster_name, String
retval[i]=ch;
ch.connect(cluster_name);
if(i == 0)
Util.sleep(3000);
Util.sleep(500);
}
return retval;
}
Expand Down

0 comments on commit f3c6a11

Please sign in to comment.