Skip to content

Commit 5c69640

Browse files
committed
Update ConfigRegionStateMachine.java
1 parent cadcac4 commit 5c69640

1 file changed

Lines changed: 6 additions & 5 deletions

File tree

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigRegionStateMachine.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,7 @@
5858
import java.nio.ByteBuffer;
5959
import java.nio.file.Files;
6060
import java.nio.file.StandardCopyOption;
61+
import java.util.ArrayList;
6162
import java.util.Arrays;
6263
import java.util.Comparator;
6364
import java.util.List;
@@ -337,11 +338,11 @@ private void becomeLeader(final long epoch) {
337338
}
338339

339340
// Start the remaining leader services in parallel and wait for all of them to finish.
340-
final CompletableFuture<?>[] startups =
341-
leaderServiceStartups().stream()
342-
.map(startup -> startInParallelIfEpochCurrent(epoch, startup))
343-
.toArray(CompletableFuture[]::new);
344-
CompletableFuture.allOf(startups).join();
341+
final List<CompletableFuture<Void>> startups = new ArrayList<>();
342+
for (final Runnable startup : leaderServiceStartups()) {
343+
startups.add(startInParallelIfEpochCurrent(epoch, startup));
344+
}
345+
CompletableFuture.allOf(startups.toArray(new CompletableFuture[0])).join();
345346

346347
if (!isCurrentLeaderServicesEpoch(epoch)) {
347348
return;

0 commit comments

Comments
 (0)