This is an automated email from the ASF dual-hosted git repository. ptupitsyn pushed a commit to branch ignite-16771 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/ignite-16771 by this push: new 7e72cd294 testClientSendsComputeJobToTargetNodeWhenDirectConnectionExists done 7e72cd294 is described below commit 7e72cd294d8f50f0d136664dffca6d635ae3babf Author: Pavel Tupitsyn <ptupit...@apache.org> AuthorDate: Thu Apr 14 18:54:34 2022 +0300 testClientSendsComputeJobToTargetNodeWhenDirectConnectionExists done --- .../src/test/java/org/apache/ignite/client/ClientComputeTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/modules/client/src/test/java/org/apache/ignite/client/ClientComputeTest.java b/modules/client/src/test/java/org/apache/ignite/client/ClientComputeTest.java index b4c72f8ef..4234205f1 100644 --- a/modules/client/src/test/java/org/apache/ignite/client/ClientComputeTest.java +++ b/modules/client/src/test/java/org/apache/ignite/client/ClientComputeTest.java @@ -24,6 +24,7 @@ import java.util.Set; import java.util.function.Function; import java.util.stream.Collectors; import org.apache.ignite.client.fakes.FakeIgnite; +import org.apache.ignite.internal.testframework.IgniteTestUtils; import org.apache.ignite.internal.util.IgniteUtils; import org.apache.ignite.network.ClusterNode; import org.apache.ignite.network.NetworkAddress; @@ -48,7 +49,7 @@ public class ClientComputeTest { initServers(reqId -> false); try (var client = getClient()) { - Thread.sleep(500); + IgniteTestUtils.waitForCondition(() -> client.connections().size() == 3, 3000); String res1 = client.compute().<String>execute(getClusterNodes("s1"), "job").join(); String res2 = client.compute().<String>execute(getClusterNodes("s2"), "job").join();