(ignite-3) branch main updated: IGNITE-21843 ItRebalanceDistributedTest silently fails to start TableManager (#3480)

[mpochatkin]

This is an automated email from the ASF dual-hosted git repository.

mpochatkin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 095aeb01c0 IGNITE-21843 ItRebalanceDistributedTest silently fails to 
start TableManager (#3480)
095aeb01c0 is described below

commit 095aeb01c0b489ed8e14e3868970034c7ab3beac
Author: Vadim Pakhnushev <8614891+valep...@users.noreply.github.com>
AuthorDate: Tue Mar 26 14:06:23 2024 +0300

    IGNITE-21843 ItRebalanceDistributedTest silently fails to start 
TableManager (#3480)
---
 .../ignite/internal/rebalance/ItRebalanceDistributedTest.java | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git 
a/modules/table/src/integrationTest/java/org/apache/ignite/internal/rebalance/ItRebalanceDistributedTest.java
 
b/modules/table/src/integrationTest/java/org/apache/ignite/internal/rebalance/ItRebalanceDistributedTest.java
index f7ea1e764e..85452dafb0 100644
--- 
a/modules/table/src/integrationTest/java/org/apache/ignite/internal/rebalance/ItRebalanceDistributedTest.java
+++ 
b/modules/table/src/integrationTest/java/org/apache/ignite/internal/rebalance/ItRebalanceDistributedTest.java
@@ -20,7 +20,6 @@ package org.apache.ignite.internal.rebalance;
 import static java.util.concurrent.CompletableFuture.allOf;
 import static java.util.concurrent.TimeUnit.MILLISECONDS;
 import static java.util.concurrent.TimeUnit.SECONDS;
-import static java.util.function.Function.identity;
 import static java.util.stream.Collectors.toSet;
 import static 
org.apache.ignite.internal.catalog.CatalogService.DEFAULT_SCHEMA_NAME;
 import static 
org.apache.ignite.internal.distributionzones.rebalance.RebalanceUtil.REBALANCE_SCHEDULER_POOL_SIZE;
@@ -83,6 +82,7 @@ import java.util.function.Function;
 import java.util.function.LongFunction;
 import java.util.function.LongSupplier;
 import java.util.function.Predicate;
+import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 import 
org.apache.ignite.client.handler.configuration.ClientConnectorConfiguration;
 import org.apache.ignite.internal.affinity.AffinityUtils;
@@ -1111,7 +1111,6 @@ public class ItRebalanceDistributedTest extends 
BaseIgniteAbstractTest {
                     
metaStorageManager.registerRevisionUpdateListener(function::apply);
 
             GcConfiguration gcConfig = 
clusterConfigRegistry.getConfiguration(GcConfiguration.KEY);
-            TransactionConfiguration txConfig = 
clusterConfigRegistry.getConfiguration(TransactionConfiguration.KEY);
 
             DataStorageModules dataStorageModules = new 
DataStorageModules(List.of(
                     new PersistentPageMemoryDataStorageModule(),
@@ -1210,7 +1209,7 @@ public class ItRebalanceDistributedTest extends 
BaseIgniteAbstractTest {
                     name,
                     registry,
                     gcConfig,
-                    txConfig,
+                    txConfiguration,
                     storageUpdateConfiguration,
                     clusterService.messagingService(),
                     clusterService.topologyService(),
@@ -1306,7 +1305,7 @@ public class ItRebalanceDistributedTest extends 
BaseIgniteAbstractTest {
                     cmgManager
             );
 
-            firstComponents.forEach(IgniteComponent::start);
+            List<CompletableFuture<?>> componentFuts = 
firstComponents.stream().map(IgniteComponent::start).collect(Collectors.toList());
 
             nodeComponents.addAll(firstComponents);
 
@@ -1326,7 +1325,7 @@ public class ItRebalanceDistributedTest extends 
BaseIgniteAbstractTest {
                         indexManager
                 );
 
-                secondComponents.forEach(IgniteComponent::start);
+                
componentFuts.addAll(secondComponents.stream().map(IgniteComponent::start).collect(Collectors.toList()));
 
                 nodeComponents.addAll(secondComponents);
 
@@ -1343,7 +1342,7 @@ public class ItRebalanceDistributedTest extends 
BaseIgniteAbstractTest {
                 lowWatermark.scheduleUpdates();
 
                 return metaStorageManager.deployWatches();
-            }).thenCompose(identity());
+            
}).thenCombine(allOf(componentFuts.toArray(CompletableFuture[]::new)), 
(deployWatchesFut, unused) -> null);
         }
 
         /**